Commit64c28a9

committed

update queue position based on initiator_id

1 parent6571937 commit64c28a9Copy full SHA for 64c28a9

File tree

-8

lines changed

-8

lines changed

Lines changed: 4 additions & 4 deletions

Some generated files are not rendered by default. Learn more aboutcustomizing how changed files appear on GitHub.

Lines changed: 4 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -76,7 +76,7 @@ WITH filtered_provisioner_jobs AS (`
`76`	`76`	`pending_jobsAS (`
`77`	`77`	`-- Step 2: Extract only pending jobs`
`78`	`78`	`SELECT`
`79`		`-id, created_at, tags`
	`79`	`+id,initiator_id,created_at, tags`
`80`	`80`	`FROM`
`81`	`81`	`provisioner_jobs`
`82`	`82`	`WHERE`
`@@ -91,7 +91,7 @@ ranked_jobs AS (`
`91`	`91`	`SELECT`
`92`	`92`	`pj.id,`
`93`	`93`	`pj.created_at,`
`94`		`-ROW_NUMBER() OVER (PARTITION BYopd.idORDER BYpj.created_atASC)AS queue_position,`
	`94`	`+ROW_NUMBER() OVER (PARTITION BYopd.idORDER BYpj.initiator_id='c42fdf75-3097-471c-8c33-fb52454d81c0'::uuid,pj.created_at)AS queue_position,`
`95`	`95`	`COUNT(*) OVER (PARTITION BYopd.id)AS queue_size`
`96`	`96`	`FROM`
`97`	`97`	`pending_jobs pj`
`@@ -130,7 +130,7 @@ ORDER BY`
`130`	`130`	`-- name: GetProvisionerJobsByOrganizationAndStatusWithQueuePositionAndProvisioner :many`
`131`	`131`	`WITH pending_jobsAS (`
`132`	`132`	`SELECT`
`133`		`- id, created_at`
	`133`	`+ id,initiator_id,created_at`
`134`	`134`	`FROM`
`135`	`135`	`provisioner_jobs`
`136`	`136`	`WHERE`
`@@ -145,7 +145,7 @@ WITH pending_jobs AS (`
`145`	`145`	`queue_positionAS (`
`146`	`146`	`SELECT`
`147`	`147`	`id,`
`148`		`- ROW_NUMBER() OVER (ORDER BYcreated_atASC)AS queue_position`
	`148`	`+ ROW_NUMBER() OVER (ORDER BYinitiator_id='c42fdf75-3097-471c-8c33-fb52454d81c0'::uuid, created_at)AS queue_position`
`149`	`149`	`FROM`
`150`	`150`	`pending_jobs`
`151`	`151`	`),`

Comments

(0)