Add time to header for load time tracking.

lsst-dm · Nov 21, 2024 · 2ab2e06 · 2ab2e06
1 parent 8d54009
commit 2ab2e06
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/main.py b/src/main.py
@@ -352,9 +352,11 @@ def dispatch_fanned_out_messages(client: httpx.AsyncClient,
         Whether or not Knative requests can be retried.
     """
     try:
+
         attributes = {
             "type": "com.example.kafka",
             "source": topic,
+            "time": str(time.time())
         }
 
         for fan_out_message in send_info.fan_out_messages: