rename pre-pull image to deployment

Author: nicktrn

apps/kubernetes-provider/src/index.ts

@@ -4,7 +4,7 @@ import {
   TaskOperations,
   TaskOperationsCreateOptions,
   TaskOperationsIndexOptions,
-  TaskOperationsPrePullImageOptions,
+  TaskOperationsPrePullDeploymentOptions,
   TaskOperationsRestoreOptions,
 } from "@trigger.dev/core-apps/provider";
 import { SimpleLogger } from "@trigger.dev/core-apps/logger";
@@ -315,7 +315,7 @@ class KubernetesTaskOperations implements TaskOperations {
     await this.#getPod(opts.runId, this.#namespace);
   }
 
-  async prePullImage(opts: TaskOperationsPrePullImageOptions) {
+  async prePullDeployment(opts: TaskOperationsPrePullDeploymentOptions) {
     const metaName = this.#getPrePullContainerName(opts.shortCode);
 
     const metaLabels = {
@@ -474,7 +474,7 @@ class KubernetesTaskOperations implements TaskOperations {
       | TaskOperationsIndexOptions
       | TaskOperationsCreateOptions
       | TaskOperationsRestoreOptions
-      | TaskOperationsPrePullImageOptions
+      | TaskOperationsPrePullDeploymentOptions
   ): Record<string, string> {
     return {
       env: opts.envId,

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

@@ -134,7 +134,7 @@ export class CreateDeployedBackgroundWorkerService extends BaseService {
       }
 
       if (deployment.imageReference) {
-        socketIo.providerNamespace.emit("PRE_PULL_IMAGE", {
+        socketIo.providerNamespace.emit("PRE_PULL_DEPLOYMENT", {
           version: "v1",
           imageRef: deployment.imageReference,
           shortCode: deployment.shortCode,

packages/core-apps/src/provider.ts

@@ -64,7 +64,7 @@ export interface TaskOperationsRestoreOptions {
   checkpointId: string;
 }
 
-export interface TaskOperationsPrePullImageOptions {
+export interface TaskOperationsPrePullDeploymentOptions {
   shortCode: string;
   imageRef: string;
   // identifiers
@@ -87,7 +87,7 @@ export interface TaskOperations {
   delete?: (...args: any[]) => Promise<any>;
   get?: (...args: any[]) => Promise<any>;
 
-  prePullImage?: (opts: TaskOperationsPrePullImageOptions) => Promise<any>;
+  prePullDeployment?: (opts: TaskOperationsPrePullDeploymentOptions) => Promise<any>;
 }
 
 type ProviderShellOptions = {
@@ -290,14 +290,14 @@ export class ProviderShell implements Provider {
             logger.error("restore failed", error);
           }
         },
-        PRE_PULL_IMAGE: async (message) => {
-          if (!this.tasks.prePullImage) {
-            logger.debug("prePullImage not implemented", message);
+        PRE_PULL_DEPLOYMENT: async (message) => {
+          if (!this.tasks.prePullDeployment) {
+            logger.debug("prePullDeployment not implemented", message);
             return;
           }
 
           try {
-            await this.tasks.prePullImage({
+            await this.tasks.prePullDeployment({
               shortCode: message.shortCode,
               imageRef: message.imageRef,
               // identifiers
@@ -308,7 +308,7 @@ export class ProviderShell implements Provider {
               deploymentId: message.deploymentId,
             });
           } catch (error) {
-            logger.error("prePullImage failed", error);
+            logger.error("prePullDeployment failed", error);
           }
         },
       },

packages/core/src/v3/schemas/messages.ts

@@ -367,7 +367,7 @@ export const PlatformToProviderMessages = {
       runId: z.string(),
     }),
   },
-  PRE_PULL_IMAGE: {
+  PRE_PULL_DEPLOYMENT: {
     message: z.object({
       version: z.literal("v1").default("v1"),
       imageRef: z.string(),