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 {