diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2025-07-16 16:56:28 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-07-16 16:56:28 +0200 |
| commit | 0c0cf25616771cd40a9e401edcba4a5e5016f76e (patch) | |
| tree | 90fa673939a6c4c53900a6aa6eef073ad2957e34 /opendc-experiments | |
| parent | 089c449762950b4322c04f73ef7fe0e10af615df (diff) | |
Added Workflows (#359)
* Implemented Workflows for OpenDC
Diffstat (limited to 'opendc-experiments')
2 files changed, 7 insertions, 4 deletions
diff --git a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt index 72042f3c..6c325349 100644 --- a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt +++ b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt @@ -150,6 +150,8 @@ public suspend fun ComputeService.replay( entry.cpuCount, entry.memCapacity, entry.gpuCount, + entry.parents, + entry.children, flavorMeta, ), workload, diff --git a/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/TestingUtils.kt b/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/TestingUtils.kt index 7b3db348..c5411179 100644 --- a/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/TestingUtils.kt +++ b/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/TestingUtils.kt @@ -54,7 +54,6 @@ import java.time.LocalDateTime import java.time.ZoneOffset import java.util.UUID import kotlin.collections.ArrayList -import kotlin.compareTo /** * Obtain the topology factory for the test. @@ -86,15 +85,17 @@ fun createTestTask( return Task( UUID.nameUUIDFromBytes(name.toByteArray()), name, + LocalDateTime.parse(submissionTime).toInstant(ZoneOffset.UTC).toEpochMilli(), + duration, + emptySet(), + emptySet(), fragments.maxOf { it.cpuCoreCount() }, fragments.maxOf { it.cpuUsage }, + 1800000.0, memCapacity, gpuCount = fragments.maxOfOrNull { it.gpuCoreCount() } ?: 0, gpuCapacity = fragments.maxOfOrNull { it.gpuUsage } ?: 0.0, gpuMemCapacity = fragments.maxOfOrNull { it.gpuMemoryUsage } ?: 0L, - 1800000.0, - LocalDateTime.parse(submissionTime).toInstant(ZoneOffset.UTC).toEpochMilli(), - duration, "", -1, TraceWorkload( |