From 76c38622dec125bb89a38c83ee0d2ab0c6eb3ae5 Mon Sep 17 00:00:00 2001
From: Brian Mesick <bmesick@tcril.org>
Date: Mon, 25 Mar 2024 16:48:58 -0400
Subject: [PATCH] feat: Store load test run

Allows the monitor to wait until the run starts and share the run id with the load test script.
---
 .../management/commands/load_test_tracking_events.py          | 2 +-
 .../management/commands/monitor_load_test_tracking.py         | 4 +++-
 2 files changed, 4 insertions(+), 2 deletions(-)

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 cd69ffe..d48a7fa 100644
--- a/platform_plugin_aspects/management/commands/load_test_tracking_events.py
+++ b/platform_plugin_aspects/management/commands/load_test_tracking_events.py
@@ -44,7 +44,7 @@
 
     RUNNING_IN_PLATFORM = False
 
-log = logging.getLogger(__name__)
+log = logging.getLogger("tracking_event_loadtest")
 
 
 class LoadTest:
diff --git a/platform_plugin_aspects/management/commands/monitor_load_test_tracking.py b/platform_plugin_aspects/management/commands/monitor_load_test_tracking.py
index 2352bf9..32e3ab0 100644
--- a/platform_plugin_aspects/management/commands/monitor_load_test_tracking.py
+++ b/platform_plugin_aspects/management/commands/monitor_load_test_tracking.py
@@ -23,7 +23,7 @@
 except ImportError:
     confluent_kafka = None
 
-log = logging.getLogger(__name__)
+log = logging.getLogger("tracking_event_loadtest_monitor")
 
 
 class Monitor:
@@ -108,6 +108,8 @@ def test_has_ended(self) -> bool:
             timeout=self.ch_timeout_secs,
         )
 
+        log.info(response.text)
+
         # ClickHouse will respond with the ID and a newline or an empty string
         return response.text.strip() == self.run_id