(self, services)
| 354 | if not step.can_ignore()] |
| 355 | |
| 356 | async def cede_control_to_planner(self, services): |
| 357 | planner = await self._get_planning_module(services) |
| 358 | await planner.execute() |
| 359 | while not await self.is_closeable(): |
| 360 | await asyncio.sleep(10) |
| 361 | await self.close(services) |
| 362 | |
| 363 | async def run(self, services): |
| 364 | await self._init_source() |
no test coverage detected