From b0ed0f964843247d11ecfe586f1565589df95ff6 Mon Sep 17 00:00:00 2001
From: Ruben Fiszel <ruben@rubenfiszel.com>
Date: Sun, 3 Sep 2023 16:52:44 +0200
Subject: [PATCH] fix: fix setting is ready for s3 workers

---
 backend/windmill-worker/src/worker.rs | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/backend/windmill-worker/src/worker.rs b/backend/windmill-worker/src/worker.rs
index ee8e5c39a3..4583a4dc91 100644
--- a/backend/windmill-worker/src/worker.rs
+++ b/backend/windmill-worker/src/worker.rs
@@ -547,8 +547,6 @@ pub async fn run_worker<R: rsmq_async::RsmqConnection + Send + Sync + Clone + 's
         }
     });
 
-    tracing::info!(worker = %worker_name, "listening for jobs");
-
     let mut first_run = true;
 
     let mut last_executed_job: Option<Instant> = None;
@@ -561,6 +559,10 @@ pub async fn run_worker<R: rsmq_async::RsmqConnection + Send + Sync + Clone + 's
     let mut infos = BenchmarkInfo { iters: 0, timings: vec![] };
 
     let vacuum_shift = rand::thread_rng().gen_range(0..VACUUM_PERIOD);
+
+    IS_READY.store(true, Ordering::Relaxed);
+    tracing::info!(worker = %worker_name, "listening for jobs");
+
     loop {
         #[cfg(feature = "benchmark")]
         let loop_start = Instant::now();
@@ -730,10 +732,8 @@ pub async fn run_worker<R: rsmq_async::RsmqConnection + Send + Sync + Clone + 's
             }
         };
 
-        first_run = false;
-
-        if !IS_READY.load(Ordering::Relaxed) {
-            IS_READY.store(true, Ordering::Relaxed);
+        if !first_run {
+            first_run = false;
         }
 
         if *METRICS_ENABLED {