diff --git a/airbyte-scheduler/src/main/java/io/airbyte/scheduler/persistence/DefaultJobPersistence.java b/airbyte-scheduler/src/main/java/io/airbyte/scheduler/persistence/DefaultJobPersistence.java index ca1378e6ba614..f7df6986143be 100644 --- a/airbyte-scheduler/src/main/java/io/airbyte/scheduler/persistence/DefaultJobPersistence.java +++ b/airbyte-scheduler/src/main/java/io/airbyte/scheduler/persistence/DefaultJobPersistence.java @@ -330,6 +330,7 @@ private static List getJobsFromResult(Result result) { getEpoch(jobEntry, "job_created_at"), getEpoch(jobEntry, "job_updated_at")); }) + .sorted(Comparator.comparingLong(Job::getCreatedAtInSecond).reversed()) .collect(Collectors.toList()); }