bgjobs: fix success check to account for parallelism

webrecorder · Feb 20, 2025 · b3363e2 · b3363e2
1 parent f0ba699
commit b3363e2
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/backend/btrixcloud/operator/bgjobs.py b/backend/btrixcloud/operator/bgjobs.py
@@ -38,7 +38,8 @@ async def finalize_background_job(self, data: MCDecoratorSyncData) -> dict:
         job_id: str = labels.get("job_id") or metadata.get("name")
 
         status = data.object["status"]
-        success = status.get("succeeded") == 1
+        spec = data.object["spec"]
+        success = status.get("succeeded") >= spec.get("parallelism")
         completion_time = status.get("completionTime")
 
         finalized = True