dabla commented on code in PR #63489:
URL: https://github.com/apache/airflow/pull/63489#discussion_r2992762304
##########
airflow-core/src/airflow/models/trigger.py:
##########
@@ -72,6 +72,14 @@ class TriggerFailureReason(str, Enum):
TRIGGER_FAILURE = "Trigger failure"
+@cache
+def get_executors():
+ """Load configured executors (cached) and find the one responsible for
this task instance."""
+ from airflow.executors.executor_loader import ExecutorLoader
+
Review Comment:
> The triggerer should remain a "client" that reports events back to the
scheduler (or API server), not become a second scheduler that also dispatches
work to executors. Could the scheduler instead be made aware that
deferred-returning tasks should skip re-evaluation and go straight to QUEUED?
That keeps the dispatch responsibility where it belongs.
Also had same remark with Jens but I suggested yet another state, which
would be awful to manage. I like the idea of setting state directly to QUEUED,
would be nice if that works.
--
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]
