remove comments

Author: xzrderek

eval_protocol/pytest/remote_rollout_processor.py

@@ -124,17 +124,6 @@ async def _process_row(row: EvaluationRow) -> EvaluationRow:
                         status_logs.append(log)
 
                 if status_logs:
-                    # finished_logs = []
-                    # for log in status_logs:
-                    #     sd = log.get("status") or {}
-                    #     if isinstance(sd, dict) and sd.get("code") == Status.Code.FINISHED:
-                    #         finished_logs.append(log)
-                    # if len(finished_logs) > 1:
-                    #     logger.warning(
-                    #         "Found %s FINISHED status logs for rollout %s; expected at most 1. Using the first one.",
-                    #         len(finished_logs),
-                    #         row.execution_metadata.rollout_id,
-                    # )
                     # Use the first log with status information
                     status_log = status_logs[0]
                     status_dict = status_log.get("status")
@@ -162,8 +151,6 @@ async def _process_row(row: EvaluationRow) -> EvaluationRow:
                         details=status_details,
                     )
 
-                    # then add the log extras to be stuffed into row.artifacts or something
-
                     logger.info("Stopping polling for rollout %s", row.execution_metadata.rollout_id)
                     break