Remove v3.resumeTaskRunDependencies job as it's no longer used

Author: ericallam

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

@@ -25,7 +25,6 @@ import { ExpireEnqueuedRunService } from "~/v3/services/expireEnqueuedRun.server
 import { IndexDeploymentService } from "~/v3/services/indexDeployment.server";
 import { ResumeBatchRunService } from "~/v3/services/resumeBatchRun.server";
 import { ResumeTaskDependencyService } from "~/v3/services/resumeTaskDependency.server";
-import { ResumeTaskRunDependenciesService } from "~/v3/services/resumeTaskRunDependencies.server";
 import { RetryAttemptService } from "~/v3/services/retryAttempt.server";
 import { TimeoutDeploymentService } from "~/v3/services/timeoutDeployment.server";
 import { GraphileMigrationHelperService } from "./db/graphileMigrationHelper.server";
@@ -40,10 +39,6 @@ const workerCatalog = {
     id: z.string(),
   }),
   // @deprecated, moved to commonWorker.server.ts
-  "v3.resumeTaskRunDependencies": z.object({
-    attemptId: z.string(),
-  }),
-  // @deprecated, moved to commonWorker.server.ts
   "v3.resumeBatchRun": z.object({
     batchRunId: z.string(),
   }),
@@ -185,16 +180,6 @@ function getWorkerQueue() {
         },
       },
       // @deprecated, moved to commonWorker.server.ts
-      "v3.resumeTaskRunDependencies": {
-        priority: 0,
-        maxAttempts: 5,
-        handler: async (payload, job) => {
-          const service = new ResumeTaskRunDependenciesService();
-
-          return await service.call(payload.attemptId);
-        },
-      },
-      // @deprecated, moved to commonWorker.server.ts
       "v3.resumeBatchRun": {
         priority: 0,
         maxAttempts: 5,

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

@@ -18,7 +18,6 @@ import { ExecuteTasksWaitingForDeployService } from "./services/executeTasksWait
 import { ExpireEnqueuedRunService } from "./services/expireEnqueuedRun.server";
 import { ResumeBatchRunService } from "./services/resumeBatchRun.server";
 import { ResumeTaskDependencyService } from "./services/resumeTaskDependency.server";
-import { ResumeTaskRunDependenciesService } from "./services/resumeTaskRunDependencies.server";
 import { RetryAttemptService } from "./services/retryAttempt.server";
 import { TimeoutDeploymentService } from "./services/timeoutDeployment.server";
 
@@ -46,15 +45,6 @@ function initializeWorker() {
           maxAttempts: 3,
         },
       },
-      "v3.resumeTaskRunDependencies": {
-        schema: z.object({
-          attemptId: z.string(),
-        }),
-        visibilityTimeoutMs: 60_000,
-        retry: {
-          maxAttempts: 5,
-        },
-      },
       "v3.resumeBatchRun": {
         schema: z.object({
           batchRunId: z.string(),
@@ -211,10 +201,6 @@ function initializeWorker() {
       scheduleEmail: async ({ payload }) => {
         await sendEmail(payload);
       },
-      "v3.resumeTaskRunDependencies": async ({ payload }) => {
-        const service = new ResumeTaskRunDependenciesService();
-        await service.call(payload.attemptId);
-      },
       "v3.resumeBatchRun": async ({ payload }) => {
         const service = new ResumeBatchRunService();
         await service.call(payload.batchRunId);

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

@@ -1,10 +1,10 @@
+import { createRedisClient, Redis, type RedisOptions } from "@internal/redis";
 import {
   Attributes,
   Histogram,
   Meter,
   metrics,
   ObservableResult,
-  SemanticAttributes,
   SpanKind,
   startSpan,
   trace,
@@ -14,13 +14,11 @@ import {
 import { Logger } from "@trigger.dev/core/logger";
 import { calculateNextRetryDelay } from "@trigger.dev/core/v3";
 import { type RetryOptions } from "@trigger.dev/core/v3/schemas";
-import { Redis, type RedisOptions } from "@internal/redis";
-import { z } from "zod";
-import { AnyQueueItem, SimpleQueue } from "./queue.js";
+import { shutdownManager } from "@trigger.dev/core/v3/serverOnly";
 import { nanoid } from "nanoid";
 import pLimit from "p-limit";
-import { createRedisClient } from "@internal/redis";
-import { shutdownManager } from "@trigger.dev/core/v3/serverOnly";
+import { z } from "zod";
+import { AnyQueueItem, SimpleQueue } from "./queue.js";
 
 export type WorkerCatalog = {
   [key: string]: {