如果您在使用Airflow时遇到了自定义触发器日志未显示的问题,请尝试在Airflow的dag文件中添加以下代码:
from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from datetime import timedelta, datetime
def run_trigger():
# code for trigger logic
dag = DAG(
'my_dag',
start_date=datetime(2021, 1, 1),
)
trigger_task = PythonOperator(
task_id='my_trigger',
python_callable=run_trigger,
dag=dag
)
# add this line to see logs from the trigger task
trigger_task.trigger_rule = 'all_done'
具体来说,添加 trigger_task.trigger_rule = 'all_done'
这一行可以让您查看自定义触发器任务的日志。这是因为默认触发规则是 all_success
,这意味着只有当任务成功完成时才会显示日志。如果您使用自定义触发规则或 all_done
规则,日志就会开始出现。