Skip to content

Commit

Permalink
Fix formatting in InMemoryCompactionJobTrackerTest
Browse files Browse the repository at this point in the history
  • Loading branch information
patchwork01 committed Feb 21, 2025
1 parent b3fdd9f commit 092b51d
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -513,24 +513,24 @@ private CompactionJobStartedEvent addStartedJob(Instant createdTime, Instant sta
return started;
}

private CompactionJobStartedEvent addFinishedJobUncommitted(Instant createdTime, JobRunSummary summary,
String taskId) {
private CompactionJobStartedEvent addFinishedJobUncommitted(
Instant createdTime, JobRunSummary summary, String taskId) {
CompactionJobStartedEvent job = addStartedJob(createdTime, summary.getStartTime(), taskId);
tracker.fixUpdateTime(defaultUpdateTime(summary.getFinishTime()));
tracker.jobFinished(compactionFinishedEventBuilder(job, summary).taskId(taskId).build());
return job;
}

private CompactionJobStartedEvent addFinishedJobCommitted(Instant createdTime, JobRunSummary summary,
Instant committedTime, String taskId) {
private CompactionJobStartedEvent addFinishedJobCommitted(
Instant createdTime, JobRunSummary summary, Instant committedTime, String taskId) {
CompactionJobStartedEvent job = addFinishedJobUncommitted(createdTime, summary, taskId);
tracker.fixUpdateTime(defaultUpdateTime(committedTime));
tracker.jobCommitted(compactionCommittedEventBuilder(job, committedTime).taskId(taskId).build());
return job;
}

private CompactionJobStartedEvent addFailedJob(Instant createdTime, JobRunTime runTime, String taskId,
List<String> failureReasons) {
private CompactionJobStartedEvent addFailedJob(
Instant createdTime, JobRunTime runTime, String taskId, List<String> failureReasons) {
CompactionJobStartedEvent job = addStartedJob(createdTime, runTime.getStartTime(), taskId);
tracker.fixUpdateTime(defaultUpdateTime(runTime.getFinishTime()));
tracker.jobFailed(compactionFailedEventBuilder(job, runTime.getFinishTime()).failureReasons(failureReasons)
Expand Down

0 comments on commit 092b51d

Please sign in to comment.