diff options
| author | vincent van beek <vincent@vlogic.nl> | 2026-04-03 11:39:34 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2026-04-03 10:39:34 +0100 |
| commit | 61cf5ddfaf57c520428685768ba4a0ba31fda5f3 (patch) | |
| tree | 09a1e0351daa5f829f9490831a750fb7fece5127 /opendc-web/opendc-web-runner/src | |
| parent | 365f6a6105d5c6b116ccf245397ebf272db1a2b3 (diff) | |
start runner to run jobs, fix the trace path (#401)
Diffstat (limited to 'opendc-web/opendc-web-runner/src')
| -rw-r--r-- | opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt | 10 |
1 files changed, 5 insertions, 5 deletions
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}" } |