You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
defchoose_branch(self, context: Context) ->str|Iterable[str]:
# If the DAG Run is manually triggered, then return without# skipping downstream tasksdag_run: DagRun=context["dag_run"] # type: ignore[assignment]ifdag_run.run_type==DagRunType.MANUAL:
self.log.info("Externally triggered DAG_Run: allowing execution to proceed.")
returnlist(context["task"].get_direct_relative_ids(upstream=False))
We should replace all usages of DagRun.external_trigger and remove it from DB too.
The text was updated successfully, but these errors were encountered:
Now that we have explicit Dag Run types, we should not need
DagRun.external_trigger
too.Example, the following code can be changed
airflow/providers/src/airflow/providers/standard/operators/latest_only.py
Lines 52 to 58 in 49581b3
to
We should replace all usages of
DagRun.external_trigger
and remove it from DB too.The text was updated successfully, but these errors were encountered: