在 DAG 文件中定义默认参数时,在 job_name 参数前添加 'dag” 前缀。
示例代码:
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2022, 1, 1),
'email': ['airflow@example.com'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(minutes=5),
'dag_id': 'my_dag_id', # DAG ID
'job_name': 'my_job_name' # job_name 参数值
}
dag = DAG(
'my_dag_id', # DAG ID
default_args=default_args,
description='My DAG',
schedule_interval=timedelta(days=1),
)