Skip to content

Commit caa49cf

Browse files
committed
Order by started_at (desc)
Signed-off-by: Willy Lulciuc <willy.lulciuc@gmail.com>
1 parent a099140 commit caa49cf

1 file changed

Lines changed: 5 additions & 6 deletions

File tree

api/src/main/resources/marquez/db/migration/V74__alter_jobs_to_add_current_run_uuid.sql

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -3,12 +3,11 @@ CREATE INDEX jobs_current_run_uuid_idx ON jobs(current_run_uuid);
33

44
-- Backfill current runs for jobs
55
WITH latest_runs AS (
6-
SELECT DISTINCT ON (job_uuid)
7-
job_uuid, uuid AS current_run_uuid
6+
SELECT DISTINCT ON (job_uuid) job_uuid, transitioned_at, uuid AS current_run_uuid
87
FROM runs
9-
ORDER BY job_uuid, transitioned_at DESC
8+
ORDER BY job_uuid, transitioned_at DESC, started_at DESC
109
)
1110
UPDATE jobs AS j
12-
SET current_run_uuid = lr.current_run_uuid
13-
FROM latest_runs AS lr
14-
WHERE j.uuid = lr.job_uuid;
11+
SET current_run_uuid = lr.current_run_uuid
12+
FROM latest_runs AS lr
13+
WHERE j.uuid = lr.job_uuid;

0 commit comments

Comments
 (0)