fix(v3): remove executing tasks waiting to deploy

Author: ericallam

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

@@ -41,7 +41,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";
@@ -220,9 +219,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
@@ -288,7 +284,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

@@ -10,7 +10,6 @@ import {
 import { taskMetadataCacheInstance } from "~/services/taskMetadataCacheInstance.server";
 import { BaseService, ServiceValidationError } from "./baseService.server";
 import { syncDeclarativeSchedules } from "./createBackgroundWorker.server";
-import { ExecuteTasksWaitingForDeployService } from "./executeTasksWaitingForDeploy";
 import { compareDeploymentVersions } from "../utils/deploymentVersions";
 
 export type ChangeCurrentDeploymentDirection = "promote" | "rollback";
@@ -175,17 +174,6 @@ export class ChangeCurrentDeploymentService extends BaseService {
       });
     }
 
-    // Only V1 engine workers need the WAITING_FOR_DEPLOY drain — V2 runs sit
-    // in PENDING_VERSION and are handled out of band, so enqueuing here for V2
-    // just produces empty scans of the TaskRun status index.
-    const worker = await this._prisma.backgroundWorker.findFirst({
-      where: { id: deployment.workerId },
-      select: { engine: true },
-    });
-
-    if (worker?.engine === "V1") {
-      await ExecuteTasksWaitingForDeployService.enqueue(deployment.workerId);
-    }
   }
 
   async #syncSchedulesForDeployment(deployment: WorkerDeployment) {

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

@@ -14,7 +14,6 @@ import {
   stripBackgroundWorkerMetadataForStorage,
   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";
@@ -208,7 +207,6 @@ export class CreateDeploymentBackgroundWorkerServiceV3 extends BaseService {
         });
       }
 
-      await ExecuteTasksWaitingForDeployService.enqueue(backgroundWorker.id);
       await PerformDeploymentAlertsService.enqueue(deployment.id);
       await TimeoutDeploymentService.dequeue(deployment.id, this._prisma);