我不确定这是否应该是这样,但可以说我正在做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出现?
我不确定这是否应该像这样,但是可以说我正在做4个任务,而我只放了3个任务,为什么第4个任务也同时显示并运行?例如:...
操作员有一个trigger_rule,它定义如何触发任务。默认的all_success规则指示当所有上游相关任务都达到成功状态时,应触发任务。如果未指定上游,则触发dag时将触发任务。