From 2fc90e6bada96c879473a948fda54827959c6800 Mon Sep 17 00:00:00 2001 From: Matt Peck Date: Thu, 1 Jan 2026 20:00:26 +0000 Subject: [PATCH 1/2] fix/correct state transition requirements --- packages/core/src/transitions/snooze-transition.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/core/src/transitions/snooze-transition.ts b/packages/core/src/transitions/snooze-transition.ts index 8bcd5c54..4f2c3276 100644 --- a/packages/core/src/transitions/snooze-transition.ts +++ b/packages/core/src/transitions/snooze-transition.ts @@ -10,7 +10,7 @@ import { JobTransition } from "./transition"; * If the job is currently running, it will decrement the attempt count. * This allows the job to be retried after the delay. * - * Only jobs in "waiting" or "running" state can be snoozed. + * Only jobs in "claimed" or "running" state can be snoozed. */ export class SnoozeTransition extends JobTransition { /** The delay in milliseconds. */ @@ -40,6 +40,6 @@ export class SnoozeTransition extends JobTransition { } shouldRun(job: JobData): boolean { - return ["waiting", "running"].includes(job.state); + return ["claimed", "running"].includes(job.state); } } From 924b537f6bb99e42f20a8eae98bbe8d02309d21f Mon Sep 17 00:00:00 2001 From: Matt Peck Date: Fri, 2 Jan 2026 19:18:01 +0000 Subject: [PATCH 2/2] fix: also include waiting in snooze transition --- packages/core/src/transitions/snooze-transition.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/core/src/transitions/snooze-transition.ts b/packages/core/src/transitions/snooze-transition.ts index 4f2c3276..639a03fb 100644 --- a/packages/core/src/transitions/snooze-transition.ts +++ b/packages/core/src/transitions/snooze-transition.ts @@ -10,7 +10,7 @@ import { JobTransition } from "./transition"; * If the job is currently running, it will decrement the attempt count. * This allows the job to be retried after the delay. * - * Only jobs in "claimed" or "running" state can be snoozed. + * Only jobs in "waiting" or "claimed" or "running" state can be snoozed. */ export class SnoozeTransition extends JobTransition { /** The delay in milliseconds. */ @@ -40,6 +40,6 @@ export class SnoozeTransition extends JobTransition { } shouldRun(job: JobData): boolean { - return ["claimed", "running"].includes(job.state); + return ["waiting", "claimed", "running"].includes(job.state); } }