fix: ignoring the deserialize result error

antonko · Mar 30, 2024 · 4535aca · 4535aca
1 parent 997a4f8
commit 4535aca
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/backend/src/services/job_service.py b/backend/src/services/job_service.py
@@ -62,7 +62,11 @@ async def fetch_job_info(
             if status == arq.jobs.JobStatus.complete:
                 complete_key: str = arq.constants.result_key_prefix + key_id_without_prefix
                 redis_raw = await redis.get(complete_key)
-                job_result: arq.jobs.JobResult = arq.jobs.deserialize_result(redis_raw)
+                try:
+                    job_result: arq.jobs.JobResult = arq.jobs.deserialize_result(redis_raw)
+                except Exception as e:
+                    self.logger.error(f"Error deserializing job result: {e}")
+                    return None
 
                 job_schema = Job(
                     id=key_id_without_prefix,