Ensure rollback triggers execution of tasks waiting for deploy

Author: nicktrn

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,
     };