starred/windmill
1
0
Fork 0
mirror of https://github.com/windmill-labs/windmill.git synced 2026-09-21 00:02:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: fix setting is ready for s3 workers

Browse Source
This commit is contained in:
Ruben Fiszel
2023-09-03 16:52:44 +02:00
parent a4d1c987d4
commit b0ed0f9648
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/windmill-worker/src/worker.rs
+6 -6
View File
@@ -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 {