即使我没有向上游或下游提供气流,任务也会出现

问题描述 投票:1回答:1

我不确定这是否应该是这样,但可以说我正在做4个任务,而我只放了3个任务,为什么第4个任务也同时显示并运行?] >

EX:

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2018, 1, 1),
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 1,
    'retry_delay': timedelta(minutes=5),
}

dag = DAG('example_dag_one',
            schedule_interval='@daily',
            catchup=False,
            default_args=default_args)

t1 = BashOperator(
    task_id='start',
    bash_command='stuff',
    dag=dag)

t2 = BashOperator(
    task_id='test',
    bash_command='stuff',
    dag=dag)

    t3 = BashOperator(
        task_id='stop',
        bash_command='more stuff',
        dag=dag)
t4 = BashOperator(
        task_id='test2',
        bash_command='more stuff',
        dag=dag)

t1>>t2>>t3

所以我希望只有3个任务会显示在我的dag中,但由于某种原因,所有4个任务都会显示。为什么t4出现?

enter image description here

我不确定这是否应该像这样,但是可以说我正在做4个任务,而我只放了3个任务,为什么第4个任务也同时显示并运行?例如:...

python airflow airflow-scheduler
1个回答
0
投票

操作员有一个trigger_rule,它定义如何触发任务。默认的all_success规则指示当所有上游相关任务都达到成功状态时,应触发任务。如果未指定上游,则触发dag时将触发任务。

© www.soinside.com 2019 - 2024. All rights reserved.