Skip to content

Commit 859355f

Browse files
committed
possible fix for in_progress
1 parent f936848 commit 859355f

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
@@ -754,10 +754,8 @@ impl PostgresConnection {
754754
UNION
755755
SELECT tag FROM parents
756756
)
757-
SELECT job_queue.*
758-
FROM requests
759-
-- Only get requests that have some jobs
760-
RIGHT JOIN job_queue on job_queue.request_tag = requests.tag
757+
-- Only get the jobs of in_progress requests
758+
SELECT * FROM job_queue WHERE job_queue.request_tag IN (SELECT * FROM requests)
761759
")).await.unwrap(),
762760
}),
763761
conn,

0 commit comments

Comments
 (0)