From 13a3f376fec17d5dcb60b635414c64a6d6ea3b13 Mon Sep 17 00:00:00 2001 From: Dante Niewenhuis Date: Tue, 16 Sep 2025 18:41:42 +0200 Subject: updated workflow implementation for performance (#368) * Updated the workflow system for performance. Added workflow specific tests. --- .../src/main/kotlin/org/opendc/trace/formats/workload/parquet/Task.kt | 2 +- .../org/opendc/trace/formats/workload/parquet/TaskRecordMaterializer.kt | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) (limited to 'opendc-trace/opendc-trace-api/src/main') diff --git a/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/workload/parquet/Task.kt b/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/workload/parquet/Task.kt index f661d5a9..0ebac5eb 100644 --- a/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/workload/parquet/Task.kt +++ b/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/workload/parquet/Task.kt @@ -37,7 +37,7 @@ internal data class Task( val memCapacity: Double, val gpuCount: Int = 0, val gpuCapacity: Double = 0.0, - val parents: Set = emptySet(), + val parents: MutableSet = mutableSetOf(), val children: Set = emptySet(), val nature: String? = null, val deadline: Long = -1, diff --git a/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/workload/parquet/TaskRecordMaterializer.kt b/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/workload/parquet/TaskRecordMaterializer.kt index 12dc54b7..1b22e2a7 100644 --- a/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/workload/parquet/TaskRecordMaterializer.kt +++ b/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/workload/parquet/TaskRecordMaterializer.kt @@ -170,7 +170,7 @@ internal class TaskRecordMaterializer(schema: MessageType) : RecordMaterializer< localMemCapacity, localGpuCount, localGpuCapacity, - localParents.toSet(), + localParents.toMutableSet(), localChildren.toSet(), localNature, localDeadline, -- cgit v1.2.3