Skip to content

Commit

Permalink
switch order of actual and expected in asserts
Browse files Browse the repository at this point in the history
  • Loading branch information
salamonpavel committed Nov 25, 2024
1 parent ba52d4e commit b5122c8
Showing 1 changed file with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -393,9 +393,9 @@ class GetFlowCheckpointsIntegrationTests extends DBTestSuite {
assert(row1.getOffsetDateTime("checkpoint_start_time").contains(startTime3))
assert(row1.getOffsetDateTime("checkpoint_end_time").contains(endTime3))
assert(row1.getLong("id_partitioning").contains(partitioningId))
val expectingPartitioningJson1 = parseJsonBStringOrThrow(partitioning)
val expectedPartitioningJson1 = parseJsonBStringOrThrow(partitioning)
val returnedPartitioningJson1 = parseJsonBStringOrThrow(row1.getJsonB("partitioning").get)
assert(expectingPartitioningJson1 == returnedPartitioningJson1)
assert(returnedPartitioningJson1 == expectedPartitioningJson1)
assert(row1.getString("partitioning_author").contains("Joseph"))

val measure1 = MeasuredDetails(
Expand All @@ -414,9 +414,9 @@ class GetFlowCheckpointsIntegrationTests extends DBTestSuite {
assert(row2.getOffsetDateTime("checkpoint_start_time").contains(startTime3))
assert(row2.getOffsetDateTime("checkpoint_end_time").contains(endTime3))
assert(row2.getLong("id_partitioning").contains(partitioningId))
val expectingPartitioningJson2 = parseJsonBStringOrThrow(partitioning)
val expectedPartitioningJson2 = parseJsonBStringOrThrow(partitioning)
val returnedPartitioningJson2 = parseJsonBStringOrThrow(row2.getJsonB("partitioning").get)
assert(expectingPartitioningJson2 == returnedPartitioningJson2)
assert(returnedPartitioningJson2 == expectedPartitioningJson2)
assert(row2.getString("partitioning_author").contains("Joseph"))

val measure2 = MeasuredDetails(
Expand All @@ -437,9 +437,9 @@ class GetFlowCheckpointsIntegrationTests extends DBTestSuite {
assert(row3.getOffsetDateTime("checkpoint_start_time").contains(startTime1))
assert(row3.getOffsetDateTime("checkpoint_end_time").contains(endTime1))
assert(row3.getLong("id_partitioning").contains(partitioningId))
val expectingPartitioningJson3 = parseJsonBStringOrThrow(partitioning)
val expectedPartitioningJson3 = parseJsonBStringOrThrow(partitioning)
val returnedPartitioningJson3 = parseJsonBStringOrThrow(row2.getJsonB("partitioning").get)
assert(expectingPartitioningJson3 == returnedPartitioningJson3)
assert(returnedPartitioningJson3 == expectedPartitioningJson3)
assert(row3.getString("partitioning_author").contains("Joseph"))

val measure3 = MeasuredDetails(
Expand All @@ -458,9 +458,9 @@ class GetFlowCheckpointsIntegrationTests extends DBTestSuite {
assert(row4.getOffsetDateTime("checkpoint_start_time").contains(startTime1))
assert(row4.getOffsetDateTime("checkpoint_end_time").contains(endTime1))
assert(row4.getLong("id_partitioning").contains(partitioningId))
val expectingPartitioningJson4 = parseJsonBStringOrThrow(partitioning)
val expectedPartitioningJson4 = parseJsonBStringOrThrow(partitioning)
val returnedPartitioningJson4 = parseJsonBStringOrThrow(row2.getJsonB("partitioning").get)
assert(expectingPartitioningJson4 == returnedPartitioningJson4)
assert(returnedPartitioningJson4 == expectedPartitioningJson4)
assert(row4.getString("partitioning_author").contains("Joseph"))

val measure4 = MeasuredDetails(
Expand Down

0 comments on commit b5122c8

Please sign in to comment.