raise exception on set_job_status() if redis set fails

getsentry · Oct 1, 2024 · 5cce7a1 · 5cce7a1
1 parent 8cc8ca0
commit 5cce7a1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/snuba/manual_jobs/runner.py b/snuba/manual_jobs/runner.py
@@ -84,7 +84,8 @@ def _release_job_lock(job_id: str) -> None:
 
 
 def _set_job_status(job_id: str, status: JobStatus) -> JobStatus:
-    _redis_client.set(name=_build_job_status_key(job_id), value=status.value)
+    if not _redis_client.set(name=_build_job_status_key(job_id), value=status.value):
+        raise SerializableException(f"Failed to set job status {status} on {job_id}")
     return status