From c232f6260e6d41ce5e9ac1c930a050690680c704 Mon Sep 17 00:00:00 2001 From: Fabian Mastenbroek Date: Mon, 24 Feb 2020 17:16:39 +0100 Subject: feat: Add support for workflow tasks with known duration This change adds support for workflow tasks that have a known duration. This allows the workflow scheduler to employ heuristics for a faster schedule. --- .../main/kotlin/com/atlarge/opendc/format/trace/gwf/GwfTraceReader.kt | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'opendc/opendc-format/src') diff --git a/opendc/opendc-format/src/main/kotlin/com/atlarge/opendc/format/trace/gwf/GwfTraceReader.kt b/opendc/opendc-format/src/main/kotlin/com/atlarge/opendc/format/trace/gwf/GwfTraceReader.kt index 498e2d1d..3a4e2e89 100644 --- a/opendc/opendc-format/src/main/kotlin/com/atlarge/opendc/format/trace/gwf/GwfTraceReader.kt +++ b/opendc/opendc-format/src/main/kotlin/com/atlarge/opendc/format/trace/gwf/GwfTraceReader.kt @@ -30,6 +30,7 @@ import com.atlarge.opendc.format.trace.TraceEntry import com.atlarge.opendc.format.trace.TraceReader import com.atlarge.opendc.workflows.workload.Job import com.atlarge.opendc.workflows.workload.Task +import com.atlarge.opendc.workflows.workload.WORKFLOW_TASK_DEADLINE import java.io.BufferedReader import java.io.File import java.io.InputStream @@ -121,7 +122,8 @@ class GwfTraceReader(reader: BufferedReader) : TraceReader { val task = Task( UUID(0L, taskId), "", FlopsApplicationImage(UUID.randomUUID(), "", emptyMap(), flops, cores), - HashSet() + HashSet(), + mapOf(WORKFLOW_TASK_DEADLINE to runtime) ) entry.submissionTime = min(entry.submissionTime, submitTime) (workflow.tasks as MutableSet).add(task) -- cgit v1.2.3