starred/windmill
1
0
Fork 0
mirror of https://github.com/windmill-labs/windmill.git synced 2026-08-19 08:01:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

reschedule to at least 1secs in future

Browse Source
This commit is contained in:
Ruben Fiszel
2024-05-26 05:04:42 +02:00
parent 7a36f30fe3
commit e397a385e2
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/windmill-queue/src/jobs.rs
+2 -1
View File
@@ -1798,7 +1798,8 @@ pub async fn pull<R: rsmq_async::RsmqConnection + Send + Clone>(
.unwrap_or_default();
let now = min_started_at.now.unwrap();
let min_started_p_inc = min_started_at.min_started_at.unwrap_or(now) + inc;
let min_started_p_inc = (min_started_at.min_started_at.unwrap_or(now) + inc)
.max(now + Duration::try_seconds(1).unwrap_or_default());
let mut estimated_next_schedule_timestamp = min_started_p_inc;
loop {