From 3ba1d08c2db07c88a01a000d9632aed322dba9db Mon Sep 17 00:00:00 2001 From: root Date: Fri, 10 Jul 2026 08:25:30 +0200 Subject: [PATCH] fix: validate runner runtime for manual dispatch --- src/mgr/server.ts | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/mgr/server.ts b/src/mgr/server.ts index 4cf2652..d5c6516 100644 --- a/src/mgr/server.ts +++ b/src/mgr/server.ts @@ -73,8 +73,7 @@ function runnerJobDefaultsForRequest(defaults: ManagerServerOptions["runnerJobDe }; } -function assertRunnerDispatcherRuntimeConfigured(enabled: boolean, defaults: ManagerServerOptions["runnerJobDefaults"]): void { - if (!enabled) return; +function assertRunnerRuntimeConfigured(defaults: ManagerServerOptions["runnerJobDefaults"]): void { const required = [ ["AGENTRUN_RUNTIME_NAMESPACE", defaults?.namespace ?? process.env.AGENTRUN_RUNTIME_NAMESPACE], ["AGENTRUN_INTERNAL_MGR_URL", defaults?.managerUrl ?? process.env.AGENTRUN_INTERNAL_MGR_URL], @@ -220,7 +219,7 @@ export async function startManagerServer(options: ManagerServerOptions = {}): Pr const runnerDispatcherOptions = runnerDispatcherOptionsForRuntime(options.runnerDispatcherOptions); const kafkaOutboxRelayOptions = kafkaOutboxRelayOptionsForRuntime(options.kafkaOutboxRelayOptions); const resolvedRunnerJobDefaults = runnerJobDefaultsForRequest(runnerJobDefaults, sourceCommit); - assertRunnerDispatcherRuntimeConfigured(runnerDispatcherOptions.enabled, runnerJobDefaults); + assertRunnerRuntimeConfigured(runnerJobDefaults); const aipodSpecDir = options.aipodSpecDir ?? process.env.AGENTRUN_AIPOD_SPEC_DIR; const auth = options.auth ?? managerServerAuthConfigFromEnv(); const authSummary = managerAuthSummary(auth);