airflow3-建议迁移到 provider (AIR312)

来源于 Airflow 代码检查器。

有时提供修复。

此规则不稳定且处于预览状态。使用需要 --preview 标志。

作用

检查对已迁移到 Airflow providers 但仍有兼容层（例如，apache-airflow-providers-standard）的 Airflow 函数和值的使用情况。

为什么这不好？

Airflow 3.0 将各种已弃用的函数、成员和其他值迁移到其 providers。即使这些符号在 Airflow 3.0 上仍然可以正常工作，但预计将在未来版本中删除。建议用户安装相应的 provider 并将原始用法替换为 provider 中的用法。

示例

from airflow.operators.python import PythonOperator


def print_context(ds=None, **kwargs):
    print(kwargs)
    print(ds)


print_the_context = PythonOperator(
    task_id="print_the_context", python_callable=print_context
)

建议改为

from airflow.providers.standard.operators.python import PythonOperator


def print_context(ds=None, **kwargs):
    print(kwargs)
    print(ds)


print_the_context = PythonOperator(
    task_id="print_the_context", python_callable=print_context
)