AutomationDev85 commented on PR #43737: URL: https://github.com/apache/airflow/pull/43737#issuecomment-2490606968
@jscheffl Sorry I had to rework again because if oversaw that the function _process_tasks in BaseExecutor delete the key ouf of the queued_tasks. See [_del self.queued_tasks[key]](https://github.com/apache/airflow/blob/main/airflow/executors/base_executor.py#L407). So I added an overload on the _process_tasks function to store the queued_tasks in an own variable. What is your opinion about this solution? Not happy about this but looking forward to remove this with Airflow 3. -- 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]
