[airflow] 01/04: Fix celery executor bug trying to call len on map (#14883)

[ka...@apache.org]

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 <25...@users.noreply.github.com>
AuthorDate: Tue Apr 6 05:21:38 2021 -0400

    Fix celery executor bug trying to call len on map (#14883)
    
    Co-authored-by: RNHTTR <ry...@wiftapp.com>
    (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):