From b3363e2dcf8d79460f3541f5751c0713314f04ab Mon Sep 17 00:00:00 2001 From: Ilya Kreymer Date: Thu, 20 Feb 2025 14:12:26 -0800 Subject: [PATCH] bgjobs: fix success check to account for parallelism --- backend/btrixcloud/operator/bgjobs.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/backend/btrixcloud/operator/bgjobs.py b/backend/btrixcloud/operator/bgjobs.py index dc7cb63d77..a7d481c551 100644 --- 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