fix(v3): remove executing tasks waiting to deploy

Author: ericallam

apps/webapp/app/services/worker.server.ts

@@ -20,7 +20,6 @@ import {
 } from "~/v3/services/cancelDevSessionRuns.server";
 import { CancelTaskAttemptDependenciesService } from "~/v3/services/cancelTaskAttemptDependencies.server";
 import { EnqueueDelayedRunService } from "~/v3/services/enqueueDelayedRun.server";
-import { ExecuteTasksWaitingForDeployService } from "~/v3/services/executeTasksWaitingForDeploy";
 import { ExpireEnqueuedRunService } from "~/v3/services/expireEnqueuedRun.server";
 import { ResumeBatchRunService } from "~/v3/services/resumeBatchRun.server";
 import { ResumeTaskDependencyService } from "~/v3/services/resumeTaskDependency.server";
@@ -199,9 +198,6 @@ function getWorkerQueue() {
         priority: 0,
         maxAttempts: 5,
         handler: async (payload, job) => {
-          const service = new ExecuteTasksWaitingForDeployService();
-
-          return await service.call(payload.backgroundWorkerId);
         },
       },
       // @deprecated, moved to ScheduleEngine
@@ -267,7 +263,7 @@ function getWorkerQueue() {
       "v3.requeueTaskRun": {
         priority: 0,
         maxAttempts: 3,
-        handler: async (payload, job) => {}, // This is now handled by redisWorker
+        handler: async (payload, job) => { }, // This is now handled by redisWorker
       },
       // @deprecated, moved to commonWorker.server.ts
       "v3.retryAttempt": {

apps/webapp/app/v3/commonWorker.server.ts

@@ -14,7 +14,6 @@ import { BatchTriggerV3Service } from "./services/batchTriggerV3.server";
 import { CancelDevSessionRunsService } from "./services/cancelDevSessionRuns.server";
 import { CancelTaskAttemptDependenciesService } from "./services/cancelTaskAttemptDependencies.server";
 import { EnqueueDelayedRunService } from "./services/enqueueDelayedRun.server";
-import { ExecuteTasksWaitingForDeployService } from "./services/executeTasksWaitingForDeploy";
 import { ExpireEnqueuedRunService } from "./services/expireEnqueuedRun.server";
 import { ResumeBatchRunService } from "./services/resumeBatchRun.server";
 import { ResumeTaskDependencyService } from "./services/resumeTaskDependency.server";
@@ -226,8 +225,6 @@ function initializeWorker() {
         await service.call(payload.deploymentId, payload.fromStatus, payload.errorMessage);
       },
       "v3.executeTasksWaitingForDeploy": async ({ payload }) => {
-        const service = new ExecuteTasksWaitingForDeployService();
-        await service.call(payload.backgroundWorkerId);
       },
       "v3.retryAttempt": async ({ payload }) => {
         const service = new RetryAttemptService();

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

@@ -1,6 +1,5 @@
 import { WorkerDeployment } from "@trigger.dev/database";
 import { BaseService, ServiceValidationError } from "./baseService.server";
-import { ExecuteTasksWaitingForDeployService } from "./executeTasksWaitingForDeploy";
 import { compareDeploymentVersions } from "../utils/deploymentVersions";
 import { CURRENT_DEPLOYMENT_LABEL } from "@trigger.dev/core/v3/isomorphic";
 
@@ -95,7 +94,5 @@ export class ChangeCurrentDeploymentService extends BaseService {
         deploymentId: deployment.id,
       },
     });
-
-    await ExecuteTasksWaitingForDeployService.enqueue(deployment.workerId);
   }
 }

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

@@ -7,7 +7,6 @@ import { updateEnvConcurrencyLimits } from "../runQueue.server";
 import { PerformDeploymentAlertsService } from "./alerts/performDeploymentAlerts.server";
 import { BaseService } from "./baseService.server";
 import { createWorkerResources, syncDeclarativeSchedules } from "./createBackgroundWorker.server";
-import { ExecuteTasksWaitingForDeployService } from "./executeTasksWaitingForDeploy";
 import { projectPubSub } from "./projectPubSub.server";
 import { TimeoutDeploymentService } from "./timeoutDeployment.server";
 import { CURRENT_DEPLOYMENT_LABEL, BackgroundWorkerId } from "@trigger.dev/core/v3/isomorphic";
@@ -162,7 +161,6 @@ export class CreateDeploymentBackgroundWorkerServiceV3 extends BaseService {
         });
       }
 
-      await ExecuteTasksWaitingForDeployService.enqueue(backgroundWorker.id);
       await PerformDeploymentAlertsService.enqueue(deployment.id);
       await TimeoutDeploymentService.dequeue(deployment.id, this._prisma);