diff options
| author | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-11-16 15:49:46 +0100 |
|---|---|---|
| committer | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-11-16 15:49:46 +0100 |
| commit | 1cfd967d6d27f339b264449ff2a1adeb705de598 (patch) | |
| tree | 6dc98eb37c05f7b07adff1d4e085f16c35727f6b /opendc-experiments/opendc-experiments-capelin/src/main | |
| parent | 381c7589cbf01ca6ed321c58c8a3a9cbea6ebd84 (diff) | |
feat(workflow): Add helper tools for workflow simulations
This change adds a new module, opendc-workflow-workload that contains
helper code for constructing workflow simulations using OpenDC.
Diffstat (limited to 'opendc-experiments/opendc-experiments-capelin/src/main')
| -rw-r--r-- | opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/Portfolio.kt | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/Portfolio.kt b/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/Portfolio.kt index 53c9de11..b548ae58 100644 --- a/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/Portfolio.kt +++ b/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/Portfolio.kt @@ -24,8 +24,8 @@ package org.opendc.experiments.capelin import com.typesafe.config.ConfigFactory import mu.KotlinLogging +import org.opendc.compute.workload.ComputeServiceHelper import org.opendc.compute.workload.ComputeWorkloadLoader -import org.opendc.compute.workload.ComputeWorkloadRunner import org.opendc.compute.workload.createComputeScheduler import org.opendc.compute.workload.export.parquet.ParquetComputeMetricExporter import org.opendc.compute.workload.grid5000 @@ -109,7 +109,7 @@ abstract class Portfolio(name: String) : Experiment(name) { grid5000(Duration.ofSeconds((operationalPhenomena.failureFrequency * 60).roundToLong())) else null - val runner = ComputeWorkloadRunner( + val runner = ComputeServiceHelper( coroutineContext, clock, computeScheduler, |