From bd2b60bed27b8557cfe6397c3da2a6da692f49a1 Mon Sep 17 00:00:00 2001 From: Cristhian Garcia Date: Wed, 25 Oct 2023 15:46:09 -0500 Subject: [PATCH] refactor: only listen to event bus --- event_routing_backends/config.py | 14 -------------- event_routing_backends/signals.py | 22 +++------------------- 2 files changed, 3 insertions(+), 33 deletions(-) delete mode 100644 event_routing_backends/config.py diff --git a/event_routing_backends/config.py b/event_routing_backends/config.py deleted file mode 100644 index 1e12614c..00000000 --- a/event_routing_backends/config.py +++ /dev/null @@ -1,14 +0,0 @@ -""" -This module contains various configuration settings via -waffle switches for the Certificates app. -""" - -from edx_toggles.toggles import SettingToggle, WaffleSwitch - -# .. toggle_name: SEND_TRACKING_EVENT_EMITTED_SIGNAL -# .. toggle_implementation: SettingToggle -# .. toggle_default: False -# .. toggle_description: When True, the system will publish `TRACKING_EVENT_EMITTED` signals to the event bus. The -# `TRACKING_EVENT_EMITTED` signal is emit when a tracking log is emitted. -# .. toggle_use_cases: publish -SEND_TRACKING_EVENT_EMITTED_SIGNAL = SettingToggle('SEND_TRACKING_EVENT_EMITTED_SIGNAL', default=True, module_name=__name__) diff --git a/event_routing_backends/signals.py b/event_routing_backends/signals.py index 4742a363..db6ebf59 100644 --- a/event_routing_backends/signals.py +++ b/event_routing_backends/signals.py @@ -1,29 +1,13 @@ -import json import logging -from django.conf import settings from django.dispatch import receiver -from openedx_events.analytics.signals import TRACKING_EVENT_EMITTED -from openedx_events.event_bus import get_producer - -from event_routing_backends.config import SEND_TRACKING_EVENT_EMITTED_SIGNAL +from openedx_events.analytics.signals import TRACKING_EVENT_EMITTED_TO_BUS logger = logging.getLogger(__name__) -TRANSFORMED_EVENT_KEY_NAME = "transformed_events" - -@receiver(TRACKING_EVENT_EMITTED) +@receiver(TRACKING_EVENT_EMITTED_TO_BUS) def listen_for_tracking_event_emitted_event(sender, signal, **kwargs): """ Publish `TRACKING_EVENT_EMITTED` events to the event bus. """ - - if SEND_TRACKING_EVENT_EMITTED_SIGNAL.is_enabled(): - logger.info("Sending events to event bus in batch") - get_producer().send( - signal=TRACKING_EVENT_EMITTED, - topic='analytics', - event_key_field='tracking_log.name', - event_data={'tracking_log': kwargs['tracking_log']}, - event_metadata=kwargs['metadata'] - ) + print("\nSay hi from event bus\n")