diff --git a/packages/cli-v3/src/entryPoints/dev-run-worker.ts b/packages/cli-v3/src/entryPoints/dev-run-worker.ts index 3d20547be..3baf55519 100644 --- a/packages/cli-v3/src/entryPoints/dev-run-worker.ts +++ b/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"; diff --git a/packages/cli-v3/src/entryPoints/managed-run-worker.ts b/packages/cli-v3/src/entryPoints/managed-run-worker.ts index 298695dd5..5d192e81b 100644 --- a/packages/cli-v3/src/entryPoints/managed-run-worker.ts +++ b/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"; diff --git a/packages/core/src/v3/runtime/managedRuntimeManager.ts b/packages/core/src/v3/runtime/sharedRuntimeManager.ts similarity index 98% rename from packages/core/src/v3/runtime/managedRuntimeManager.ts rename to packages/core/src/v3/runtime/sharedRuntimeManager.ts index eccd97cf1..855866e12 100644 --- a/packages/core/src/v3/runtime/managedRuntimeManager.ts +++ b/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 = 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); } diff --git a/packages/core/src/v3/workers/index.ts b/packages/core/src/v3/workers/index.ts index de89b5587..5ff626f2e 100644 --- a/packages/core/src/v3/workers/index.ts +++ b/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";