airflow-variable-name-task-id-mismatch (AIR001)

来源于 Airflow 代码检查器。

作用

检查 Airflow Operators 的任务变量名是否与 task_id 值匹配。

为什么这不好？

初始化 Airflow Operator 时，为了保持一致性，变量名应与 task_id 值匹配。 这样可以更轻松地跟踪 DAG 的流程。

示例

from airflow.operators import PythonOperator


incorrect_name = PythonOperator(task_id="my_task")

建议改为

from airflow.operators import PythonOperator


my_task = PythonOperator(task_id="my_task")