[TWTR][CX-17516] Queue tasks even if already being handled by the exe…

…cutor
twitter-forks · Dec 10, 2019 · e6fa402 · e6fa402
1 parent 67a4d1c
commit e6fa402
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/airflow/jobs.py b/airflow/jobs.py
@@ -1224,10 +1224,9 @@ def _find_executable_task_instances(self, simple_dag_bag, states, session=None):
 
                 if self.executor.has_task(task_instance):
                     self.log.debug(
-                        "Not handling task %s as the executor reports it is running",
+                        "Still handling task %s even though as the executor reports it is running",
                         task_instance.key
                     )
-                    continue
                 executable_tis.append(task_instance)
                 open_slots -= 1
                 dag_id_to_possibly_running_task_count[dag_id] += 1

diff --git a/airflow/version.py b/airflow/version.py
@@ -18,4 +18,4 @@
 # under the License.
 #
 
-version = '1.10.0+twtr23'
+version = '1.10.0+twtr24'