From 5d342edadacb063eb081d2bc2d54742c4a4c123a Mon Sep 17 00:00:00 2001 From: Cristhian Garcia Date: Fri, 9 Feb 2024 14:16:35 -0500 Subject: [PATCH] fix: mark signals as already emitted by event bus --- edx_event_bus_redis/internal/consumer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/edx_event_bus_redis/internal/consumer.py b/edx_event_bus_redis/internal/consumer.py index b968695..96b6a64 100644 --- a/edx_event_bus_redis/internal/consumer.py +++ b/edx_event_bus_redis/internal/consumer.py @@ -282,7 +282,7 @@ def emit_signals_from_message(self, msg: RedisMessage): signal = OpenEdxPublicSignal.get_signal_by_type(msg.event_metadata.event_type) event_data = deserialize_bytes_to_event_data(msg.event_data, signal) - send_results = signal.send_event_with_custom_metadata(msg.event_metadata, **event_data) + send_results = signal.send_event_with_custom_metadata(msg.event_metadata, **event_data, from_event_bus=True) # Raise an exception if any receivers errored out. This allows logging of the receivers # along with partition, offset, etc. in record_event_consuming_error. Hopefully the # receiver code is idempotent and we can just replay any messages that were involved.