Airflow DAG新增第三任务不显示问题求助

作为Airflow新手，已成功让DAG中的前两个任务正常运行，但添加第三个与首个任务类似的BashOperator任务后，测试时提示「任务未找到」，执行airflow list_tasks mydag也无法看到该任务。

正常任务代码 #

START_TASK = BashOperator(
    task_id='start_task',
    bash_command="echo 'Successfully Started'",
    dag=dedup_dag
)

异常任务代码 #

mv_task = BashOperator(
    task_id = "randomized_name_task",
    bash_command = "mkdir -p /data/airflow/keywordstep1; gsutil cp gs://airflow-dev-test/keywordstep1/000000_0 /data/airflow/keywordstep1/infile",
    dag_id = dedup_dag
)

排查思路 #

• 修正参数错误：对比正常任务代码，异常任务误用了dag_id参数，Airflow Operator绑定DAG对象的正确参数是dag。将dag_id = dedup_dag改为dag = dedup_dag，这是最直接的修复点。
• 验证DAG加载：修改代码后，重启Airflow Webserver和Scheduler服务，确保DAG文件被重新加载。可以查看Airflow日志，确认没有语法错误导致DAG加载失败。
• 检查任务ID唯一性：确认randomized_name_task在当前DAG中唯一，没有与其他任务的task_id重复。
• 确认文件有效性：检查DAG文件的权限是否允许Airflow读取，文件名是否符合规范（以.py结尾，无特殊字符）。

内容的提问来源于stack exchange，提问作者Mark McWiggins