rename managed to shared runtime manager

Author: nicktrn

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

@@ -35,7 +35,7 @@ import {
   getEnvVar,
   getNumberEnvVar,
   logLevels,
-  ManagedRuntimeManager,
+  SharedRuntimeManager,
   OtelTaskLogger,
   populateEnv,
   StandardLifecycleHooksManager,
@@ -456,7 +456,7 @@ const zodIpc = new ZodIpcConnection({
       await flushAll(timeoutInMs);
     },
     WAITPOINT_COMPLETED: async ({ waitpoint }) => {
-      managedWorkerRuntime.completeWaitpoints([waitpoint]);
+      sharedWorkerRuntime.completeWaitpoints([waitpoint]);
     },
   },
 });
@@ -528,8 +528,8 @@ async function flushMetadata(timeoutInMs: number = 10_000) {
   };
 }
 
-const managedWorkerRuntime = new ManagedRuntimeManager(zodIpc, showInternalLogs);
-runtime.setGlobalRuntimeManager(managedWorkerRuntime);
+const sharedWorkerRuntime = new SharedRuntimeManager(zodIpc, showInternalLogs);
+runtime.setGlobalRuntimeManager(sharedWorkerRuntime);
 
 process.title = "trigger-managed-worker";
 

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

@@ -34,7 +34,7 @@ import {
   getEnvVar,
   getNumberEnvVar,
   logLevels,
-  ManagedRuntimeManager,
+  SharedRuntimeManager,
   OtelTaskLogger,
   populateEnv,
   ProdUsageManager,
@@ -449,7 +449,7 @@ const zodIpc = new ZodIpcConnection({
       await flushAll(timeoutInMs);
     },
     WAITPOINT_COMPLETED: async ({ waitpoint }) => {
-      managedWorkerRuntime.completeWaitpoints([waitpoint]);
+      sharedWorkerRuntime.completeWaitpoints([waitpoint]);
     },
   },
 });
@@ -556,9 +556,9 @@ function initializeUsageManager({
   timeout.setGlobalManager(new UsageTimeoutManager(devUsageManager));
 }
 
-const managedWorkerRuntime = new ManagedRuntimeManager(zodIpc, true);
+const sharedWorkerRuntime = new SharedRuntimeManager(zodIpc, true);
 
-runtime.setGlobalRuntimeManager(managedWorkerRuntime);
+runtime.setGlobalRuntimeManager(sharedWorkerRuntime);
 
 process.title = "trigger-managed-worker";
 

…/src/v3/runtime/managedRuntimeManager.ts …e/src/v3/runtime/sharedRuntimeManager.tspackages/core/src/v3/runtime/managedRuntimeManager.ts renamed to packages/core/src/v3/runtime/sharedRuntimeManager.ts packages/core/src/v3/runtime/managedRuntimeManager.ts renamed to packages/core/src/v3/runtime/sharedRuntimeManager.ts

@@ -15,7 +15,7 @@ import { preventMultipleWaits } from "./preventMultipleWaits.js";
 
 type Resolver = (value: CompletedWaitpoint) => void;
 
-export class ManagedRuntimeManager implements RuntimeManager {
+export class SharedRuntimeManager implements RuntimeManager {
   // Maps a resolver ID to a resolver function
   private readonly resolversByWaitId: Map<string, Resolver> = new Map();
   // Maps a waitpoint ID to a wait ID
@@ -29,7 +29,7 @@ export class ManagedRuntimeManager implements RuntimeManager {
   ) {
     // Log out the runtime status on a long interval to help debug stuck executions
     setInterval(() => {
-      this.log("[DEBUG] ManagedRuntimeManager status", this.status);
+      this.log("[DEBUG] SharedRuntimeManager status", this.status);
     }, 300_000);
   }
 

packages/core/src/v3/workers/index.ts

@@ -21,7 +21,7 @@ export { ProdUsageManager, type ProdUsageManagerOptions } from "../usage/prodUsa
 export { UsageTimeoutManager } from "../timeout/usageTimeoutManager.js";
 export { StandardMetadataManager } from "../runMetadata/manager.js";
 export { StandardWaitUntilManager } from "../waitUntil/manager.js";
-export { ManagedRuntimeManager } from "../runtime/managedRuntimeManager.js";
+export { SharedRuntimeManager } from "../runtime/sharedRuntimeManager.js";
 export * from "../runEngineWorker/index.js";
 export { StandardRunTimelineMetricsManager } from "../runTimelineMetrics/runTimelineMetricsManager.js";
 export { WarmStartClient, type WarmStartClientOptions } from "../workers/warmStartClient.js";