(self, task_name: str, inst: Platform)
| 47 | return sanitized, sanitized != platform_id |
| 48 | |
| 49 | def _start_platform_task(self, task_name: str, inst: Platform) -> None: |
| 50 | run_task = asyncio.create_task(inst.run(), name=task_name) |
| 51 | wrapper_task = asyncio.create_task( |
| 52 | self._task_wrapper(run_task, platform=inst), |
| 53 | name=f"{task_name}_wrapper", |
| 54 | ) |
| 55 | self._platform_tasks[inst.client_self_id] = PlatformTasks( |
| 56 | run=run_task, |
| 57 | wrapper=wrapper_task, |
| 58 | ) |
| 59 | |
| 60 | async def _stop_platform_task(self, client_id: str) -> None: |
| 61 | tasks = self._platform_tasks.pop(client_id, None) |
no test coverage detected