dstandish commented on code in PR #33570:
URL: https://github.com/apache/airflow/pull/33570#discussion_r1306476712
##########
airflow/ti_deps/deps/trigger_rule_dep.py:
##########
@@ -94,33 +98,41 @@ def _get_dep_statuses(
session: Session,
dep_context: DepContext,
) -> Iterator[TIDepStatus]:
+ # get all the setup tasks upstream of this task
+ setup_upstream_tasks = list(ti.task.get_upstreams_only_setups())
# Checking that all upstream dependencies have succeeded.
if not ti.task.upstream_task_ids:
yield self._passing_status(reason="The task instance did not have
any upstream tasks.")
return
- if ti.task.trigger_rule == TR.ALWAYS:
+ if ti.task.trigger_rule == TR.ALWAYS and not setup_upstream_tasks:
+ # even with ALWAYS trigger rule, we still need to check setup tasks
Review Comment:
i think always should probably keep the same behavior. it says in the docs
`No dependencies at all, run this task at any time`. it used to be called
"dummy" trigger rule. so i think we just keep the absolute short circuit here.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
