Ветвь воздушного потока, Python, цепочка операторов - PullRequest
Новая
       2

Ветвь воздушного потока, Python, цепочка операторов

0 голосов
/ 16 июня 2020

Я пытаюсь использовать Airflow BranchPythonOperator. Я получил сообщение об ошибке: 

def next_task(x):
  if x : return "branch_data"
  else: return "branch_no_data"

branch_task  = BranchPythonOperator(
   task_id = 'branch_task',
   python_callable = next_task,
   op_args = [x],
   dag = dag
)

branch_no_data=DummyOperator(task_id="branch_no_data", dag=dag)
branch_data=DummyOperator(task_id="branch_data", dag=dag)
join_task=DummyOperator(task_id="join_task", dag=dag)
branch_task >> [branch_data, branch_no_data ]  >>  join_task

Мне нужно выполнить только одну из двух задач (branch_data, branch_no_data). Ниже моя неудачная попытка реализовать цепочку задач. Получил ошибку: 

branch_task >> [branch_data, branch_no_data ]  >>  join_task
TypeError: unsupported operand type(s) for >>: 'BranchPythonOperator' and 'list'
...