add callback_queue in lunary update track_event params

ShoggothAI · May 20, 2024 · afa0e31 · afa0e31
1 parent 0a55be4
commit afa0e31
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/motleycrew/caching/http_cache.py b/motleycrew/caching/http_cache.py
@@ -22,7 +22,7 @@
 from curl_cffi.requests import Headers as CurlCFFI__Headers
 
 try:
-    from lunary import track_event, run_ctx
+    from lunary import track_event, run_ctx, event_queue_ctx
 
     is_update_lunary_event = True
 except ImportError:
@@ -217,6 +217,7 @@ def _update_lunary_event(
             "run_type": run_type,
             "event_name": LunaryEventName.UPDATE,
             "run_id": run_id,
+            "callback_queue": event_queue_ctx.get()
         }
         if is_cache:
             event_params["metadata"] = {"cache": True}