diff --git a/apps/webapp/app/v3/services/expireEnqueuedRun.server.ts b/apps/webapp/app/v3/services/expireEnqueuedRun.server.ts index 0c4b2be1fb..2ccde4d82d 100644 --- a/apps/webapp/app/v3/services/expireEnqueuedRun.server.ts +++ b/apps/webapp/app/v3/services/expireEnqueuedRun.server.ts @@ -49,6 +49,14 @@ export class ExpireEnqueuedRunService extends BaseService { return; } + if (run.lockedAt) { + logger.debug("Run cannot be expired because it's locked", { + run, + }); + + return; + } + logger.debug("Expiring enqueued run", { run, });