From 61cf5ddfaf57c520428685768ba4a0ba31fda5f3 Mon Sep 17 00:00:00 2001 From: vincent van beek Date: Fri, 3 Apr 2026 11:39:34 +0200 Subject: start runner to run jobs, fix the trace path (#401) --- .../src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'opendc-web/opendc-web-runner') diff --git a/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt b/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt index d41400e3..33f8c94d 100644 --- a/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt +++ b/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt @@ -268,12 +268,12 @@ public class OpenDCRunner( val topology = listOf(ClusterSpec("cluster", topologyHosts, powerSourceSpec)) Provisioner(dispatcher, seed).use { provisioner -> + // Create a trace-specific workload loader + val traceId = scenario.workload.trace.id + val traceSpecificPath = tracePath.resolve(traceId) + val traceLoader = ComputeWorkloadLoader(traceSpecificPath) -// val workload = -// trace(scenario.workload.trace.id).sampleByLoad(scenario.workload.samplingFraction) -// val vms = workload.resolve(workloadLoader, Random(seed)) - - val vms = workloadLoader.sampleByLoad(scenario.workload.samplingFraction) + val vms = traceLoader.sampleByLoad(scenario.workload.samplingFraction) val startTime = vms.minOf { it.submittedAt } logger.debug { "Using scheduler: '${scenario.schedulerName}' for scenario ${scenario.id}" } -- cgit v1.2.3