summaryrefslogtreecommitdiff
path: root/opendc-trace/opendc-trace-wtf/src/test/kotlin
diff options
context:
space:
mode:
authorFabian Mastenbroek <mail.fabianm@gmail.com>2022-04-16 11:32:28 +0200
committerFabian Mastenbroek <mail.fabianm@gmail.com>2022-04-22 20:18:55 +0200
commitb6698d96fb1313909705604be2daf1170ea40d68 (patch)
tree91b01df54833017b94e5a1b2d43dd1dfcbf29c62 /opendc-trace/opendc-trace-wtf/src/test/kotlin
parentf74f8d5adc240137f49c1b215004f9f17d0c213d (diff)
refactor(trace/api): Move conventions into separate package
This change moves the trace conventions (such as table and column names) in a separate conv package, so that it is separated from the main API. This also allows for a potential move into a separate module in the future.
Diffstat (limited to 'opendc-trace/opendc-trace-wtf/src/test/kotlin')
-rw-r--r--opendc-trace/opendc-trace-wtf/src/test/kotlin/org/opendc/trace/wtf/WtfTraceFormatTest.kt20
1 files changed, 17 insertions, 3 deletions
diff --git a/opendc-trace/opendc-trace-wtf/src/test/kotlin/org/opendc/trace/wtf/WtfTraceFormatTest.kt b/opendc-trace/opendc-trace-wtf/src/test/kotlin/org/opendc/trace/wtf/WtfTraceFormatTest.kt
index 09c3703a..0f0e422d 100644
--- a/opendc-trace/opendc-trace-wtf/src/test/kotlin/org/opendc/trace/wtf/WtfTraceFormatTest.kt
+++ b/opendc-trace/opendc-trace-wtf/src/test/kotlin/org/opendc/trace/wtf/WtfTraceFormatTest.kt
@@ -25,7 +25,7 @@ package org.opendc.trace.wtf
import org.junit.jupiter.api.Assertions.*
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.assertThrows
-import org.opendc.trace.*
+import org.opendc.trace.conv.*
import java.nio.file.Paths
import java.time.Duration
import java.time.Instant
@@ -69,7 +69,14 @@ class WtfTraceFormatTest {
{ assertEquals("1078341553348591493", reader.get(TASK_WORKFLOW_ID)) },
{ assertEquals(Instant.ofEpochMilli(245604), reader.get(TASK_SUBMIT_TIME)) },
{ assertEquals(Duration.ofMillis(8163), reader.get(TASK_RUNTIME)) },
- { assertEquals(setOf("584055316413447529", "133113685133695608", "1008582348422865408"), reader.get(TASK_PARENTS)) },
+ {
+ assertEquals(
+ setOf("584055316413447529", "133113685133695608", "1008582348422865408"),
+ reader.get(
+ TASK_PARENTS
+ )
+ )
+ },
)
assertAll(
@@ -78,7 +85,14 @@ class WtfTraceFormatTest {
{ assertEquals("1078341553348591493", reader.get(TASK_WORKFLOW_ID)) },
{ assertEquals(Instant.ofEpochMilli(251325), reader.get(TASK_SUBMIT_TIME)) },
{ assertEquals(Duration.ofMillis(8216), reader.get(TASK_RUNTIME)) },
- { assertEquals(setOf("584055316413447529", "133113685133695608", "1008582348422865408"), reader.get(TASK_PARENTS)) },
+ {
+ assertEquals(
+ setOf("584055316413447529", "133113685133695608", "1008582348422865408"),
+ reader.get(
+ TASK_PARENTS
+ )
+ )
+ },
)
reader.close()