diff --git a/arq/jobs.py b/arq/jobs.py index 78bd0c32..f9211a4c 100644 --- 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', ''), ) except Exception as e: raise DeserializationError('unable to deserialize job result') from e