diff --git a/libs/io/garf/io/writers/topic_writer.py b/libs/io/garf/io/writers/topic_writer.py index 7beef6e2..336ebae3 100644 --- a/libs/io/garf/io/writers/topic_writer.py +++ b/libs/io/garf/io/writers/topic_writer.py @@ -84,7 +84,7 @@ def write(self, report: garf_report.GarfReport, destination: str) -> str: for batch in _batched(report, self.batch_size): data = [row.to_dict() for row in batch] self._send(data=json.dumps(data).encode('utf-8'), topic=topic) - return f'[self.provider] - published message to {topic}' + return f'[{self.provider}] - published message to {topic}' def _batched(report: garf_report.GarfReport, chunk_size: int):