From 09f5cc8b4ddbe3b409d76ae44dd1702c0c3a4fe5 Mon Sep 17 00:00:00 2001
From: Matt Aitken <matt@mattaitken.com>
Date: Mon, 18 Aug 2025 14:57:37 +0100
Subject: [PATCH] Fix for v4 pending versions not getting dequeued after a
 deploy
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

We didn’t call `scheduleEnqueueRunsForBackgroundWorker` in the right
place…
---
 .../app/v3/services/finalizeDeployment.server.ts   | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

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;