如何覆盖气流 DAG 中特定任务的参数

Question

我有一个包含两个 tasks.The DAG 的 DAG，如下所示：

default_args = {
    'catchup': False,
    'depends_on_past': False,
    'start_date': datetime(2022, 1, 30),
    'retries': '2',
    'retry_delay': timedelta(minutes=3),
    'queue': us_constants.CELERY_QUEUE
}


 with DAG(dag.dag_id+'.'+task_id, default_args=default_args, schedule_interval=dag.schedule_interval) as temp_dag:
    
   t0 = DummyOperator(task_id='t0')
   
   t1 = DummyOperator(task_id='t1')

现在我想在同一 DAG 中将 t1 的重试值从 2 改写为 3，其中包含重试的默认参数为 2

我该怎么做。

Answer 1

只需执行：

t1 = DummyOperator(task_id='t1', retries=3)

在操作员级别传递的参数优先于 default_args 中设置的值。

如何覆盖气流 DAG 中特定任务的参数

How to override the arguement of a particular task in airflow DAG

airflow