[AIRFLOW-4311] Remove sleep in localexecutor (apache#5096)

cthenderson · Apr 16, 2019 · bb4a9eb · bb4a9eb
1 parent 48c0d3b
commit bb4a9eb
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/airflow/executors/local_executor.py b/airflow/executors/local_executor.py
@@ -46,7 +46,6 @@
 
 import multiprocessing
 import subprocess
-import time
 
 from builtins import range
 
@@ -94,7 +93,6 @@ def execute_work(self, key, command):
 
     def run(self):
         self.execute_work(self.key, self.command)
-        time.sleep(1)
 
 
 class QueuedLocalWorker(LocalWorker):
@@ -116,7 +114,6 @@ def run(self):
                 break
             self.execute_work(key, command)
             self.task_queue.task_done()
-            time.sleep(1)
 
 
 class LocalExecutor(BaseExecutor):
@@ -164,7 +161,6 @@ def sync(self):
         def end(self):
             while self.executor.workers_active > 0:
                 self.executor.sync()
-                time.sleep(0.5)
 
     class _LimitedParallelism(object):
         """Implements LocalExecutor with limited parallelism using a task queue to