(self, index: SampleIndex, session: Session)
| 61 | return list(range(len(self.data))) |
| 62 | |
| 63 | async def start_sample(self, index: SampleIndex, session: Session) -> TaskSampleExecutionResult: |
| 64 | self.env_controller.loop = asyncio.get_running_loop() |
| 65 | if not self.env_controller_background_task: |
| 66 | self.env_controller_background_task = asyncio.create_task(self.env_controller.background_task()) |
| 67 | weakref.finalize(self, self.env_controller_background_task.cancel) |
| 68 | |
| 69 | return await super().start_sample(index, session) |
| 70 | |
| 71 | def sync_start_sample(self, index: SampleIndex, session: Session) -> TaskSampleExecutionResult: |
| 72 | self.logger.info(f'starting sample {index} with session id {session.id}') |
nothing calls this directly
no outgoing calls
no test coverage detected