Skip to content

Commit

Permalink
[fix] queue_job: JobsTrap.perform_enqueued_jobs
Browse files Browse the repository at this point in the history
Closes #651
  • Loading branch information
fd-oncodna committed May 25, 2024
1 parent 897b946 commit d8499b1
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion queue_job/tests/common.py
Original file line number Diff line number Diff line change
Expand Up @@ -227,12 +227,12 @@ def by_graph(job):
return job.graph_uuid or ""

sorted_jobs = sorted(self.enqueued_jobs, key=by_graph)
self.enqueued_jobs = []
for graph_uuid, jobs in groupby(sorted_jobs, key=by_graph):
if graph_uuid:
self._perform_graph_jobs(jobs)
else:
self._perform_single_jobs(jobs)
self.enqueued_jobs = []

def _perform_single_jobs(self, jobs):
# we probably don't want to replicate a perfect order here, but at
Expand Down

0 comments on commit d8499b1

Please sign in to comment.