diff --git a/airflow/executors/local_executor.py b/airflow/executors/local_executor.py index c9454a677f832..e766c37f66399 100644 --- 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