fix initialization

This commit is contained in:
Ruben Fiszel
2023-09-03 18:12:44 +02:00
parent fa6ae22321
commit 5d3fc2b9c0
+1 -1
View File
@@ -560,7 +560,7 @@ pub async fn run_worker<R: rsmq_async::RsmqConnection + Send + Sync + Clone + 's
let vacuum_shift = rand::thread_rng().gen_range(0..VACUUM_PERIOD);
// IS_READY.store(true, Ordering::Relaxed);
IS_READY.store(true, Ordering::Relaxed);
tracing::info!(worker = %worker_name, "listening for jobs");
loop {