diff --git a/apps/webapp/app/v3/services/finalizeDeployment.server.ts b/apps/webapp/app/v3/services/finalizeDeployment.server.ts index 6e9b0c1da3..175986ae04 100644 --- a/apps/webapp/app/v3/services/finalizeDeployment.server.ts +++ b/apps/webapp/app/v3/services/finalizeDeployment.server.ts @@ -9,6 +9,8 @@ import { ChangeCurrentDeploymentService } from "./changeCurrentDeployment.server import { projectPubSub } from "./projectPubSub.server"; import { FailDeploymentService } from "./failDeployment.server"; import { TimeoutDeploymentService } from "./timeoutDeployment.server"; +import { engine } from "../runEngine.server"; +import { tryCatch } from "@trigger.dev/core"; export class FinalizeDeploymentService extends BaseService { public async call( @@ -116,6 +118,18 @@ export class FinalizeDeploymentService extends BaseService { }); } + if (deployment.worker.engine === "V2") { + const [schedulePendingVersionsError] = await tryCatch( + engine.scheduleEnqueueRunsForBackgroundWorker(deployment.worker.id) + ); + + if (schedulePendingVersionsError) { + logger.error("Error scheduling pending versions", { + error: schedulePendingVersionsError, + }); + } + } + await PerformDeploymentAlertsService.enqueue(deployment.id); return finalizedDeployment;