Skip to content

Commit

Permalink
Fix WaitForTasksTest
Browse files Browse the repository at this point in the history
  • Loading branch information
patchwork01 committed Feb 20, 2025
1 parent 450b8bf commit 945969c
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,7 @@
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.UUID;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatCode;
Expand Down Expand Up @@ -215,6 +216,7 @@ private IngestJobStartedEvent ingestJobStartedOnTask(String jobId, String taskId
return IngestJobStartedEvent.builder()
.jobId(jobId)
.taskId(taskId)
.jobRunId(UUID.randomUUID().toString())
.tableId("test-table")
.startTime(startTime)
.startOfRun(true)
Expand All @@ -225,6 +227,7 @@ private CompactionJobStartedEvent compactionJobStartedOnTask(String jobId, Strin
return CompactionJobStartedEvent.builder()
.jobId(jobId)
.taskId(taskId)
.jobRunId(UUID.randomUUID().toString())
.tableId("test-table")
.startTime(startTime)
.build();
Expand Down

0 comments on commit 945969c

Please sign in to comment.