You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
For me, the following function doesn't work as it should for queue jobs using graphs.
Somehow, all of the jobs get assigned the same graph_uuid and this is why the function below does not do the sorting correctly.
Also, priority field is not included in the sorting, which would also help to get the jobs sorting in the correct order.
def perform_enqueued_jobs(self):
"""Perform the enqueued jobs synchronously"""
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)
Can somebody explain to me where and how the graph_uuid gets assigned and why this does work for my live environment, but not in the tests?
The text was updated successfully, but these errors were encountered:
For me, the following function doesn't work as it should for queue jobs using graphs.
Somehow, all of the jobs get assigned the same graph_uuid and this is why the function below does not do the sorting correctly.
Also, priority field is not included in the sorting, which would also help to get the jobs sorting in the correct order.
Can somebody explain to me where and how the graph_uuid gets assigned and why this does work for my live environment, but not in the tests?
The text was updated successfully, but these errors were encountered: