From 0c0cf25616771cd40a9e401edcba4a5e5016f76e Mon Sep 17 00:00:00 2001
From: Dante Niewenhuis <d.niewenhuis@hotmail.com>
Date: Wed, 16 Jul 2025 16:56:28 +0200
Subject: Added Workflows (#359)

* Implemented Workflows for OpenDC
---
 .../org/opendc/experiments/base/runner/ScenarioReplayer.kt       | 2 ++
 .../src/test/kotlin/org/opendc/experiments/base/TestingUtils.kt  | 9 +++++----
 2 files changed, 7 insertions(+), 4 deletions(-)

(limited to 'opendc-experiments')

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(
-- 
cgit v1.2.3