diff --git a/platform_plugin_aspects/management/commands/load_test_tracking_events.py b/platform_plugin_aspects/management/commands/load_test_tracking_events.py index 8fe1d3c..dcb6edb 100644 --- a/platform_plugin_aspects/management/commands/load_test_tracking_events.py +++ b/platform_plugin_aspects/management/commands/load_test_tracking_events.py @@ -130,10 +130,10 @@ def record_to_clickhouse(self, event_type, extra) -> None: Send the run events to ClickHouse. """ log.info(extra) - insert = f"INSERT INTO {self.ch_runs_table} (run_id, event_type, extra) FORMAT TSV " + insert = f"INSERT INTO {self.ch_runs_table} (run_id, event_type, extra) FORMAT CSV " - output = io.StringIO(newline="\n") - writer = csv.writer(output, dialect="excel-tab") + output = io.StringIO() + writer = csv.writer(output) writer.writerow((self.run_id, event_type, json.dumps(extra))) print(output.getvalue().encode("utf-8"))