summaryrefslogtreecommitdiff
path: root/simulator/opendc-workflows/src/test
diff options
context:
space:
mode:
Diffstat (limited to 'simulator/opendc-workflows/src/test')
-rw-r--r--simulator/opendc-workflows/src/test/kotlin/org/opendc/workflows/service/StageWorkflowSchedulerIntegrationTest.kt6
1 files changed, 3 insertions, 3 deletions
diff --git a/simulator/opendc-workflows/src/test/kotlin/org/opendc/workflows/service/StageWorkflowSchedulerIntegrationTest.kt b/simulator/opendc-workflows/src/test/kotlin/org/opendc/workflows/service/StageWorkflowSchedulerIntegrationTest.kt
index 52bf3db5..eb79162c 100644
--- a/simulator/opendc-workflows/src/test/kotlin/org/opendc/workflows/service/StageWorkflowSchedulerIntegrationTest.kt
+++ b/simulator/opendc-workflows/src/test/kotlin/org/opendc/workflows/service/StageWorkflowSchedulerIntegrationTest.kt
@@ -119,10 +119,10 @@ internal class StageWorkflowSchedulerIntegrationTest {
val reader = GwfTraceReader(object {}.javaClass.getResourceAsStream("/trace.gwf"))
while (reader.hasNext()) {
- val (time, job) = reader.next()
+ val entry = reader.next()
jobsSubmitted++
- delay(max(0, time - clock.millis()))
- scheduler.submit(job)
+ delay(max(0, entry.start - clock.millis()))
+ scheduler.submit(entry.workload)
}
}