diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2025-09-16 18:41:42 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-09-16 18:41:42 +0200 |
| commit | 13a3f376fec17d5dcb60b635414c64a6d6ea3b13 (patch) | |
| tree | 02707cce678452c596424ac04eeece78e9e1a8a1 /opendc-trace/opendc-trace-api/src | |
| parent | a735f1768677fc996da77b239819c55dcd623f5e (diff) | |
updated workflow implementation for performance (#368)
* Updated the workflow system for performance. Added workflow specific tests.
Diffstat (limited to 'opendc-trace/opendc-trace-api/src')
2 files changed, 2 insertions, 2 deletions
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<Int> = emptySet(), + val parents: MutableSet<Int> = mutableSetOf(), val children: Set<Int> = 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, |