ferruzzi commented on code in PR #63482:
URL: https://github.com/apache/airflow/pull/63482#discussion_r2927978460
##########
airflow-core/src/airflow/executors/base_executor.py:
##########
@@ -184,8 +185,7 @@ def __init__(self, parallelism: int = PARALLELISM,
team_name: str | None = None)
self.parallelism: int = parallelism
self.team_name: str | None = team_name
- self.queued_tasks: dict[TaskInstanceKey, workloads.ExecuteTask] = {}
- self.queued_callbacks: dict[str, workloads.ExecuteCallback] = {}
+ self.executor_queues: dict[str, dict] = defaultdict(dict)
Review Comment:
@jscheffl - I really like the direction this PR was going and it's a huge
step toward simplifying the scheduler. Once he fixes the rebase, are you
willing to chat about what he needs to do to make this back-compat?
I think we can work something out where the old parameters are retained and
flagged as deprecated, and assemble the new executor_queues from those if they
are present
--
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]
