This is an automated email from the ASF dual-hosted git repository. kaxilnaik pushed a commit to branch v2-0-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 50a16666edc9026f35433a41916d4900557bb85a Author: Ryan Hatter <[email protected]> AuthorDate: Tue Apr 6 05:21:38 2021 -0400 Fix celery executor bug trying to call len on map (#14883) Co-authored-by: RNHTTR <[email protected]> (cherry picked from commit 4ee442970873ba59ee1d1de3ac78ef8e33666e0f) --- airflow/executors/celery_executor.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/airflow/executors/celery_executor.py b/airflow/executors/celery_executor.py index 2d0e915..a4ddfab 100644 --- a/airflow/executors/celery_executor.py +++ b/airflow/executors/celery_executor.py @@ -542,6 +542,9 @@ class BulkStateFetcher(LoggingMixin): def _tasks_list_to_task_ids(self, async_tasks) -> Set[str]: return {a.task_id for a in async_tasks} + def _tasks_list_to_task_ids(self, async_tasks) -> Set[str]: + return {a.task_id for a in async_tasks} + def get_many(self, async_results) -> Mapping[str, EventBufferValueType]: """Gets status for many Celery tasks using the best method available.""" if isinstance(app.backend, BaseKeyValueStoreBackend):
