可以通过 airflow.utils.dag_processing.generate_command() 方法生成 FailureCallbackContext 中的信息。
示例代码:
from airflow.utils.dag_processing import generate_command
def on_failure_callback(context): print(context)
dag = DAG(...) task = BashOperator( task_id='my_task', bash_command='...', on_failure_callback=on_failure_callback, dag=dag, )
...
command = generate_command(None, dag.task_dict['my_task'], None, False, None) print(command)