Airflow：如何在 PythonOperator 中使用 dag_run 参数值作为 trigger_rule

Question

我试图在触发我的 DAG 时通过配置传递 PythonOperator 的 trigger_rule。 例如：

{"trigger_rule": "all_done"}

。 换句话说，我希望能够在运行时通过在触发 DAG 时使用配置来选择要使用的 trigger_rule。

不过，PythonOperator中的trigger_rule字段好像不是模板化字段。 IE。我不能按如下方式实现它：

PythonOperator(
   task_id='test',
   python_callable=my_func,
   trigger_rule="{{ dag_run.conf.get('trigger_rule', 'all_success') }}"
)

关于如何解决这个问题的任何线索？