From e397a385e2a12fcbda9a53c8a34eb80db7a3b2dc Mon Sep 17 00:00:00 2001 From: Ruben Fiszel Date: Sun, 26 May 2024 05:04:42 +0200 Subject: [PATCH] reschedule to at least 1secs in future --- backend/windmill-queue/src/jobs.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/backend/windmill-queue/src/jobs.rs b/backend/windmill-queue/src/jobs.rs index 07ce3ea6d1..d4f5163d6d 100644 --- a/backend/windmill-queue/src/jobs.rs +++ b/backend/windmill-queue/src/jobs.rs @@ -1798,7 +1798,8 @@ pub async fn pull( .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 {