From a414e1114c7358c11876bf3f876f2d329726daee Mon Sep 17 00:00:00 2001 From: Cristhian Garcia Date: Mon, 30 Oct 2023 14:33:32 -0500 Subject: [PATCH] fix: rename tracking log event emitted --- eventtracking/backends/event_bus.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/eventtracking/backends/event_bus.py b/eventtracking/backends/event_bus.py index ca42988..2e99e4b 100644 --- a/eventtracking/backends/event_bus.py +++ b/eventtracking/backends/event_bus.py @@ -4,7 +4,7 @@ from datetime import datetime from openedx_events.analytics.data import TrackingLogData -from openedx_events.analytics.signals import TRACKING_EVENT_EMITTED +from openedx_events.analytics.signals import TRACKING_LOG_EVENT_EMITTED from openedx_events.event_bus import get_producer from eventtracking.backends.routing import RoutingBackend @@ -21,7 +21,7 @@ class EventBusRoutingBackend(RoutingBackend): def send(self, event): """ Send the tracking log event to the event bus by emitting the - TRACKING_EVENT_EMITTED signal using custom metadata. + TRACKING_LOG_EVENT_EMITTED signal using custom metadata. """ if not SEND_TRACKING_EVENT_EMITTED_SIGNAL.is_enabled(): return @@ -41,11 +41,11 @@ def send(self, event): context=context, ) - metadata = TRACKING_EVENT_EMITTED.generate_signal_metadata() + metadata = TRACKING_LOG_EVENT_EMITTED.generate_signal_metadata() logger.info(f"Sending tracking lof {tracking_log.name} to the event bus.") get_producer().send( - signal=TRACKING_EVENT_EMITTED, + signal=TRACKING_LOG_EVENT_EMITTED, topic="analytics", event_key_field="tracking_log.name", event_data={"tracking_log": tracking_log},