有没有办法在Airflow中的任务中调用任务？
有没有办法在Airflow中的任务中调用任务？
提问于 2020-01-09 18:19:34
我有以下逻辑：
def function_1():
if condition_1 == True:
function_2()
else:
function_3()
function_2()有没有办法在Airflow中调用任务中的任务？
Stack Overflow用户
发布于 2020-01-09 22:33:18
您可以使用BranchPythonOperator实现相同的功能，如下所示。
def function_1(**kwargs):
if condition_1 == True :
return 'function_2'
else:
return 'function_3'
check_task = BranchPythonOperator(
task_id='check_task',
python_callable=function_1, # defined above method holds the branching condition
provide_context=True,
dag=dag
)
function_2_task = BashOperator(
task_id= 'function_2',
bash_command="echo function_2 task executed",
dag=dag
)
function_3_task = BashOperator(
task_id= 'function_3',
bash_command="echo function_3 task executed",
dag=dag
)
function_2_task.set_upstream(check_task)
function_3_task.set_upstream(check_task)
function_3_task.set_upstream(function_2_task)
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/59661767
复制相关文章
相似问题
腾讯云开发者
