@jens

re

> exactly this is the "minor" gap. In...
>
>
> https://github.com/apache/airflow/blob/main/airflow/executors/base_executor.py#L522
>
> ... the Scheduler passes only the "executor_config" field and not the
> full TaskInstance. So an executor does not have access to "pool_slots"
> of the task. PR https://github.com/apache/airflow/pull/44016 is


The method `execute_async` is not actually called by the scheduler.  It's
something the executor does internally in `_process_tasks`, and in
*that* method,
we seem to have the full ti:

https://github.com/apache/airflow/blob/298f1fd73b500a70b48267160ad0d6bb258fd205/airflow/executors/base_executor.py#L371

But that is weird if you look at the type of queued tasks 🤦

Reply via email to