yaml.safe_dump({key: msg}, self.files_write[topic], default_flow_style=True, width=20000)
self.files_write[topic].flush()
except Exception as e: # TODO refine
yaml.safe_dump({key: msg}, self.files_write[topic], default_flow_style=True, width=20000)
self.files_write[topic].flush()
except Exception as e: # TODO refine