Parse validated progress reported by generation workers

app/generation/providers/worker_client.py

@@ -473,16 +473,24 @@ class RemoteWorkerClient:
         raw_output = payload.get("output")
         try:
             output = self._worker_output(raw_output) if isinstance(raw_output, dict) else None
+            raw_progress = payload.get("progress_percent")
+            if raw_progress is not None and (
+                not isinstance(raw_progress, int)
+                or isinstance(raw_progress, bool)
+                or not 0 <= raw_progress <= 100
+            ):
+                raise ValueError("worker progress_percent must be an integer from 0 to 100")
             return WorkerJob(
                 external_job_id=job_id,
                 status=statuses[raw_status],
+                progress_percent=raw_progress,
                 output=output,
                 error_category=self._worker_error_category(payload, statuses[raw_status]),
                 error_code=self._worker_error_code(payload),
                 error_message=None,
                 metadata=self._metadata(
                     payload,
-                    known={"job_id", "external_job_id", "status", "output", "error"},
+                    known={"job_id", "external_job_id", "status", "progress_percent", "output", "error"},
                 ),
             )
         except (TypeError, ValueError) as exc: