| 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) |
| 375 | event_logs_dir = await file_svc.create_exfil_sub_directory('%s/event_logs' % self.get_config('reports_dir')) |
| 376 | file_name = 'operation_%s.json' % self.id |
| 377 | await self._write_logs_to_disk(event_logs, file_name, event_logs_dir, file_svc) |
| 378 | logging.debug('Wrote event logs for operation %s to disk at %s/%s' % (self.name, event_logs_dir, file_name)) |
| 379 | |
| 380 | async def _write_logs_to_disk(self, logs, file_name, dest_dir, file_svc): |
| 381 | logs_dumps = json.dumps(logs) + os.linesep |