Add time to cloud event header for tracking time from knative fan out

message generation to when the message is loaded by a knative serving pod in prompt processing. Time header requires string and is converted back to float in prompt processing.
lsst-dm · Dec 3, 2024 · 34507f0 · 34507f0
1 parent 3ef17f9
commit 34507f0
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: