We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d162501 commit e5ef516Copy full SHA for e5ef516
1 file changed
eval_protocol/pytest/remote_rollout_processor.py
@@ -124,8 +124,13 @@ async def _process_row(row: EvaluationRow) -> EvaluationRow:
124
status_result = await asyncio.to_thread(
125
self._tracing_adapter.get_status, rollout_id=row.execution_metadata.rollout_id
126
)
127
- if status_result and status_result.get("status"):
128
- status_code = status_result["status"]["code"]
+ status = (status_result or {}).get("status")
+ if status and "code" in status:
129
+ status_code = status["code"]
130
+
131
+ if status_code == Status.Code.RUNNING:
132
+ await asyncio.sleep(poll_interval)
133
+ continue
134
135
logger.info(
136
"Found status for rollout %s with code %s",
0 commit comments