summaryrefslogtreecommitdiff
path: root/opendc-web/opendc-web-runner/src/cli/kotlin/org
diff options
context:
space:
mode:
Diffstat (limited to 'opendc-web/opendc-web-runner/src/cli/kotlin/org')
-rw-r--r--opendc-web/opendc-web-runner/src/cli/kotlin/org/opendc/web/runner/Main.kt3
1 files changed, 2 insertions, 1 deletions
diff --git a/opendc-web/opendc-web-runner/src/cli/kotlin/org/opendc/web/runner/Main.kt b/opendc-web/opendc-web-runner/src/cli/kotlin/org/opendc/web/runner/Main.kt
index 348a838c..4cfbdd7c 100644
--- a/opendc-web/opendc-web-runner/src/cli/kotlin/org/opendc/web/runner/Main.kt
+++ b/opendc-web/opendc-web-runner/src/cli/kotlin/org/opendc/web/runner/Main.kt
@@ -114,7 +114,8 @@ class RunnerCli : CliktCommand(name = "opendc-runner") {
logger.info { "Starting OpenDC web runner" }
val client = OpenDCRunnerClient(baseUrl = apiUrl, OpenIdAuthController(authDomain, authClientId, authClientSecret, authAudience))
- val runner = OpenDCRunner(client, tracePath, parallelism = parallelism)
+ val manager = JobManager(client)
+ val runner = OpenDCRunner(manager, tracePath, parallelism = parallelism)
logger.info { "Watching for queued scenarios" }
runner.run()