(self, services)
| 361 | await self.close(services) |
| 362 | |
| 363 | async def run(self, services): |
| 364 | await self._init_source() |
| 365 | data_svc = services.get('data_svc') |
| 366 | await self._load_objective(data_svc) |
| 367 | try: |
| 368 | await self.cede_control_to_planner(services) |
| 369 | await self.write_event_logs_to_disk(services.get('file_svc'), data_svc, output=True) |
| 370 | except Exception as e: |
| 371 | logging.error(e, exc_info=True) |
| 372 | |
| 373 | async def write_event_logs_to_disk(self, file_svc, data_svc, output=False): |
| 374 | event_logs = await self.event_logs(file_svc, data_svc, output=output) |
nothing calls this directly
no test coverage detected