Skip to content

Commit 9dd831f

Browse files
authored
Fix for v4 pending versions not getting dequeued after a deploy (#2411)
We didn’t call `scheduleEnqueueRunsForBackgroundWorker` in the right place…
1 parent 112f6f6 commit 9dd831f

File tree

1 file changed

+14
-0
lines changed

1 file changed

+14
-0
lines changed

apps/webapp/app/v3/services/finalizeDeployment.server.ts

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,8 @@ import { ChangeCurrentDeploymentService } from "./changeCurrentDeployment.server
99
import { projectPubSub } from "./projectPubSub.server";
1010
import { FailDeploymentService } from "./failDeployment.server";
1111
import { TimeoutDeploymentService } from "./timeoutDeployment.server";
12+
import { engine } from "../runEngine.server";
13+
import { tryCatch } from "@trigger.dev/core";
1214

1315
export class FinalizeDeploymentService extends BaseService {
1416
public async call(
@@ -116,6 +118,18 @@ export class FinalizeDeploymentService extends BaseService {
116118
});
117119
}
118120

121+
if (deployment.worker.engine === "V2") {
122+
const [schedulePendingVersionsError] = await tryCatch(
123+
engine.scheduleEnqueueRunsForBackgroundWorker(deployment.worker.id)
124+
);
125+
126+
if (schedulePendingVersionsError) {
127+
logger.error("Error scheduling pending versions", {
128+
error: schedulePendingVersionsError,
129+
});
130+
}
131+
}
132+
119133
await PerformDeploymentAlertsService.enqueue(deployment.id);
120134

121135
return finalizedDeployment;

0 commit comments

Comments
 (0)