有没有办法在手动触发时将参数传递给气流 dag
Is there a way to pass a parameter to an airflow dag when triggering it manually
我有一个通过 cli 从外部触发的气流 DAG。
我需要根据从 CLI 获取的布尔参数更改任务的执行顺序。
如何实现？
我了解dag_run.conf只能用于运算符的模板字段。
提前致谢。
您不能使用运行时参数更改任务依赖性。
但是您可以传递运行时参数（使用 dag_run.conf），根据它的值任务将被执行或被跳过，因为您需要在您的工作流中放置可以处理此逻辑的运算符，例如：ShortCircuitOperator, BranchPythonOperator
我有一个通过 cli 从外部触发的气流 DAG。
我需要根据从 CLI 获取的布尔参数更改任务的执行顺序。
如何实现？
我了解dag_run.conf只能用于运算符的模板字段。
提前致谢。
您不能使用运行时参数更改任务依赖性。
但是您可以传递运行时参数（使用 dag_run.conf），根据它的值任务将被执行或被跳过，因为您需要在您的工作流中放置可以处理此逻辑的运算符，例如：ShortCircuitOperator, BranchPythonOperator