Python Airflow - Resultado de retorno do PythonOperator
Eu escrevi um DAG com vários PythonOperators
task1 = af_op.PythonOperator(task_id='Data_Extraction_Environment',
provide_context=True,
python_callable=Task1, dag=dag1)
def Task1(**kwargs):
return(kwargs['dag_run'].conf.get('file'))
No PythonOperator, estou chamando o método "Task1". Esse método está retornando um valor, esse valor eu preciso passar para o próximo PythonOperator. Como posso obter o valor da variável "task1" ou Como posso obter o valor retornado do método Task1?
Atualizada :
def Task1(**kwargs):
file_name = kwargs['dag_run'].conf.get[file]
task_instance = kwargs['task_instance']
task_instance.xcom_push(key='file', value=file_name)
return file_name
t1 = PythonOperator(task_id = 'Task1',provide_context=True,python_callable=Task1,dag=dag)
t2 = BashOperator(
task_id='Moving_bucket',
bash_command='python /home/raw.py {{ task_instance.xcom_pull(task_ids='Task1',key='file') }} ',
dag=dag,
)
t2.set_upstream(t1)