Method start_sample

src/server/tasks/os_interaction/task.py:360–397

(self, index, session: Session)

        return ret

    async def start_sample(self, index, session: Session) -> TaskSampleExecutionResult:
        if not self.env_controller_background_task:
            self.env_controller_background_task = asyncio.create_task(self.env_controller.background_task())
            weakref.finalize(self, self.env_controller_background_task.cancel)

        logging.info(f"Starting sample with index: {index}")
        data_item = self.problem_configs[index]
        config = data_item["config"]
        file = data_item["file"]
        index_in_file = data_item["index"]

        container = Container(self.env_controller, config.image)
        try:
            logging.info("Initializing container")
            await container.initialize()
            logging.info("Container initialized successfully")

            logging.info("Starting judge process")
            result = await self._judge(session, config, container)
            result.result["file"] = file
            result.result["index_in_file"] = index_in_file
            logging.info(f"Judge process completed with status: {result.status}")
            return result
        except AgentCancelledException:
            session.inject(RewardHistoryItem(reward=0, score=0))
            return TaskSampleExecutionResult(status=SampleStatus.CANCELLED)
        except:
            logging.exception(f"Error in start_sample")
            session.inject(RewardHistoryItem(reward=0, score=0))
            return TaskSampleExecutionResult(
                status=SampleStatus.TASK_ERROR,
                result={"result": False, "error": traceback.format_exc()},
            )
        finally:
            try:
                await container.cleanup()
            except Exception as e:
                logging.error(f"Error during container cleanup: {str(e)}")

    async def _judge(
            self, session: Session, config: JudgeConfig, container: Container