diff --git a/lib/App/Netdisco/JobQueue/PostgreSQL.pm b/lib/App/Netdisco/JobQueue/PostgreSQL.pm index 4c9f4b66..c9f53311 100644 --- a/lib/App/Netdisco/JobQueue/PostgreSQL.pm +++ b/lib/App/Netdisco/JobQueue/PostgreSQL.pm @@ -159,10 +159,11 @@ sub jq_getsome { -and => [ %job_properties, -or => [{ - job => { '!=' => $job->id }, + job => { '<' => $job->id }, },{ job => $job->id, -exists => $jobs->search({ + job => { '>' => $job->id }, status => { -like => 'queued-%' }, started => \[q/> (now() - ?::interval)/, setting('jobs_stale_after')], %job_properties,