From afa0e3102b5a16babaaa222ef745149c33a0676b Mon Sep 17 00:00:00 2001 From: User Date: Mon, 20 May 2024 12:14:49 +0300 Subject: [PATCH] add callback_queue in lunary update track_event params --- motleycrew/caching/http_cache.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/motleycrew/caching/http_cache.py b/motleycrew/caching/http_cache.py index 7da432be..710869e9 100644 --- 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}