cope with old jobs where queue_name "q" is not available

python-arq · Apr 21, 2021 · 66ad5da · 66ad5da
1 parent 3ce4cb0
commit 66ad5da
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/arq/jobs.py b/arq/jobs.py
@@ -250,7 +250,7 @@ def deserialize_result(r: bytes, *, deserializer: Optional[Deserializer] = None)
             result=d['r'],
             start_time=ms_to_datetime(d['st']),
             finish_time=ms_to_datetime(d['ft']),
-            queue_name=d['q'],
+            queue_name=d.get('q', '<unknown>'),
         )
     except Exception as e:
         raise DeserializationError('unable to deserialize job result') from e