Ensure rollback triggers execution of tasks waiting for deploy

triggerdotdev · Jun 12, 2024 · 1d47cab · 1d47cab
1 parent e23047f
commit 1d47cab
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/apps/webapp/app/v3/services/rollbackDeployment.server.ts b/apps/webapp/app/v3/services/rollbackDeployment.server.ts
@@ -2,6 +2,7 @@ import { logger } from "~/services/logger.server";
 import { BaseService } from "./baseService.server";
 import { WorkerDeployment } from "@trigger.dev/database";
 import { CURRENT_DEPLOYMENT_LABEL } from "~/consts";
+import { ExecuteTasksWaitingForDeployService } from "./executeTasksWaitingForDeploy";
 
 export class RollbackDeploymentService extends BaseService {
   public async call(deployment: WorkerDeployment) {
@@ -39,6 +40,10 @@ export class RollbackDeploymentService extends BaseService {
       },
     });
 
+    if (deployment.workerId) {
+      await ExecuteTasksWaitingForDeployService.enqueue(deployment.workerId, this._prisma);
+    }
+
     return {
       id: deployment.id,
     };