Skip to content

Commit abbeaba

Browse files
committed
possible fix for in_progress
1 parent 6a6dadb commit abbeaba

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

database/src/pool/postgres.rs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -731,10 +731,8 @@ impl PostgresConnection {
731731
UNION
732732
SELECT tag FROM parents
733733
)
734-
SELECT job_queue.*
735-
FROM requests
736-
-- Only get requests that have some jobs
737-
RIGHT JOIN job_queue on job_queue.request_tag = requests.tag
734+
-- Only get the jobs of in_progress requests
735+
SELECT * FROM job_queue WHERE job_queue.request_tag IN (SELECT * FROM requests)
738736
")).await.unwrap(),
739737
}),
740738
conn,

0 commit comments

Comments
 (0)