Fix init.ts import for deployed workers

.changeset/twelve-actors-hide.md

@@ -0,0 +1,5 @@
+---
+"trigger.dev": patch
+---
+
+Fix init.ts auto-import for deployed workers

packages/cli-v3/src/entryPoints/dev-run-worker.ts

@@ -104,12 +104,12 @@ const heartbeatIntervalMs = getEnvVar("HEARTBEAT_INTERVAL_MS");
 const standardLocalsManager = new StandardLocalsManager();
 localsAPI.setGlobalLocalsManager(standardLocalsManager);
 
-const standardRunTimelineMetricsManager = new StandardRunTimelineMetricsManager();
-runTimelineMetrics.setGlobalManager(standardRunTimelineMetricsManager);
-
 const standardLifecycleHooksManager = new StandardLifecycleHooksManager();
 lifecycleHooks.setGlobalLifecycleHooksManager(standardLifecycleHooksManager);
 
+const standardRunTimelineMetricsManager = new StandardRunTimelineMetricsManager();
+runTimelineMetrics.setGlobalManager(standardRunTimelineMetricsManager);
+
 const devUsageManager = new DevUsageManager();
 usage.setGlobalUsageManager(devUsageManager);
 timeout.setGlobalManager(new UsageTimeoutManager(devUsageManager));

packages/cli-v3/src/entryPoints/managed-run-worker.ts

@@ -324,6 +324,18 @@ const zodIpc = new ZodIpcConnection({
             async () => {
               const beforeImport = performance.now();
               resourceCatalog.setCurrentFileContext(taskManifest.entryPoint, taskManifest.filePath);
+
+              // Load init file if it exists
+              if (workerManifest.initEntryPoint) {
+                try {
+                  await import(normalizeImportPath(workerManifest.initEntryPoint));
+                  console.log(`Loaded init file from ${workerManifest.initEntryPoint}`);
+                } catch (err) {
+                  console.error(`Failed to load init file`, err);
+                  throw err;
+                }
+              }
+
               await import(normalizeImportPath(taskManifest.entryPoint));
               resourceCatalog.clearCurrentFileContext();
               const durationMs = performance.now() - beforeImport;
@@ -439,6 +451,8 @@ const zodIpc = new ZodIpcConnection({
             error: {
               type: "INTERNAL_ERROR",
               code: TaskRunErrorCodes.CONFIGURED_INCORRECTLY,
+              message: err instanceof Error ? err.message : String(err),
+              stackTrace: err instanceof Error ? err.stack : undefined,
             },
             usage: {
               durationMs: 0,
@@ -448,10 +462,7 @@ const zodIpc = new ZodIpcConnection({
         });
       }
     },
-    FLUSH: async ({ timeoutInMs }, sender) => {
-      await flushAll(timeoutInMs);
-    },
-    CANCEL: async ({ timeoutInMs }, sender) => {
+    CANCEL: async ({ timeoutInMs }) => {
       _isCancelled = true;
       cancelController.abort("run cancelled");
       await callCancelHooks(timeoutInMs);
@@ -460,6 +471,9 @@ const zodIpc = new ZodIpcConnection({
       }
       await flushAll(timeoutInMs);
     },
+    FLUSH: async ({ timeoutInMs }) => {
+      await flushAll(timeoutInMs);
+    },
     RESOLVE_WAITPOINT: async ({ waitpoint }) => {
       sharedWorkerRuntime.resolveWaitpoints([waitpoint]);
     },