airflow - 如何修复警告 - schedule_interval 用于 虽然它已被弃用作为任务参数

Question

我不断收到警告:

WARNING - schedule_interval is used for <Task(BigQueryOperator): mytask>, though it has been deprecated as a task parameter, you need to specify it as a DAG parameter instead

我在谷歌 Composer 1.9.0

schedule_interval = datetime.timedelta(days=1)
default_args = {
    'owner': 'e',
    'catchup': False,
    'start_date': datetime.datetime(2019, 10, 25),
}


with models.DAG(
        dag_id=f"mydag",
        schedule_interval=schedule_interval,
        default_args=default_args,

) as dag:
    mytask

我该如何解决这个警告？我认为通过明确指定 schedule_interval 我可以避免这种情况。

Answer 1

我在迁移到最新的 Airflow 版本 1.10.10 时遇到了同样的问题。
该消息只是说您不仅定义了 schedule_interval在 DAG 级别(就像您在代码片段中所做的那样)，但也在任务级别。在 BigQueryOperator 任务中的示例中。但定义 schedule_interval因为一个任务已被弃用。一样的，例如retry_delay_in_hours .

要防止出现此警告，您只需从所有任务中删除此属性。
来自 DAG 的计划间隔会自动应用于任务。见 docs for more information

干杯
迈克尔