set object id as context id

thenetcircle · Oct 8, 2021 · 274810c · 274810c
1 parent 649b67d
commit 274810c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/logistik/queue/event_reader.py b/logistik/queue/event_reader.py
@@ -147,7 +147,11 @@ def create_env(self):
     def handle_event(self, topic, data):
         self.logger.info(f"request: {data}")
 
-        with self.env.tracer.start_span("handle-event", event_id=data["id"]) as span:
+        context_id = None
+        if "object" in data and "id" in data["object"]:
+            context_id = data["object"]["id"]
+
+        with self.env.tracer.start_span("handle-event", event_id=data["id"], context_id=context_id) as span:
             span.log_kv(data)
             self.handler_manager.handle_event(topic, data, span_ctx=span)