feat: Store load test run

Allows the monitor to wait until the run starts and share the run id with the load test script.

platform_plugin_aspects/management/commands/monitor_load_test_tracking.py

@@ -294,6 +294,8 @@ def get_kafka_bus_stats(self):
             "partitions": [],
         }
 
+        total_lag = 0
+
         for partition in committed:
             # Get the partitions low and high watermark offsets.
             low, high = consumer.get_watermark_offsets(
@@ -311,6 +313,7 @@ def get_kafka_bus_stats(self):
                 lag = high - partition.offset
 
             log.info(f"{partition.topic} [{partition.partition}] Lag: {lag}")
+            total_lag += lag
 
             consumer_stats["partitions"].append(
                 {
@@ -320,6 +323,7 @@ def get_kafka_bus_stats(self):
             )
 
         consumer.close()
+        consumer_stats["lag"] = total_lag
         return consumer_stats
 
     def _call_vector_graphql(self):
@@ -375,6 +379,7 @@ def get_vector_stats(self):
         )
         return rtn
 
+
 class Command(BaseCommand):
     """
     Dump objects to a ClickHouse instance.