Есть запрос с ExternalTaskSensor в Airflow - PullRequest
Новая
       8

Есть запрос с ExternalTaskSensor в Airflow

0 голосов
/ 29 мая 2019

У меня есть 2 образца дагов, которые находятся в одном файле. 

dag = DAG(
    dag_id='example_1-simpledag',
    default_args=args,
    schedule_interval=None,

dag1 = DAG(
    dag_id='example_2-simpledag',
    default_args=args,
    schedule_interval=None,

run_this1 = ExternalTaskSensor(
    task_id='wait_for_the_first_task_to_be_completed',
    external_dag_id='Vijay_example_1-simpledag',
    external_task_id='run_this',
    dag=dag)

for i in range(5):
    task = PythonOperator(
        task_id='sleep_for_' + str(i),
        python_callable=my_sleeping_function,
        op_kwargs={'random_base': float(i) / 10},
        dag=dag,
    )

    run_this >> task
    run_this1 >> task

Оба пакета созданы, но один завершен, а другой все еще находится в рабочем состоянии и не выполняется вообще. Что мне здесь не хватает, может кто-нибудь, пожалуйста, помогите мне в этом?

...