rabbitmq: Actually log size above

Flared · Jun 15, 2023 · cb274f3 · cb274f3
1 parent ce355d1
commit cb274f3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/saturn_engine/worker/topics/rabbitmq.py b/src/saturn_engine/worker/topics/rabbitmq.py
@@ -246,7 +246,7 @@ def _serialize(self, message: TopicMessage) -> bytes:
         serialized_message_len = len(serialized_message)
         if (
             self.options.log_above_size
-            and self.options.log_above_size > serialized_message_len
+            and self.options.log_above_size < serialized_message_len
         ):
             self.logger.warning(
                 "Sending large message",