From 71799121c02900f9716afba52a13121f41660884 Mon Sep 17 00:00:00 2001 From: Dragoslav Mitrinovic Date: Mon, 4 Jan 2021 14:38:58 -0600 Subject: [PATCH] Fix webserver exiting when gunicorn master crashes --- airflow/bin/cli.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/airflow/bin/cli.py b/airflow/bin/cli.py index 70a1107132a02..843282ac4409a 100644 --- a/airflow/bin/cli.py +++ b/airflow/bin/cli.py @@ -1090,13 +1090,13 @@ def _check_workers(self): num_workers_running = self._get_num_workers_running() if num_workers_running < self.num_workers_expected: new_worker_count = min( - num_workers_running - self.worker_refresh_batch_size, self.worker_refresh_batch_size + self.num_workers_expected - num_workers_running, self.worker_refresh_batch_size ) - self.log.debug( + self.log.info( '[%d / %d] Spawning %d workers', num_ready_workers_running, num_workers_running, new_worker_count ) - self._spawn_new_workers(num_workers_running) + self._spawn_new_workers(new_worker_count) return # Now the number of running and expected worker should be equal