Raise exception after logging error in publish when the queue is full

Author: U039b

mongoose/core/processing.py

@@ -74,6 +74,7 @@ def publish(self, topic: ProcessingTopic, data: Any):
                 q.put_nowait(data)
             except Full as e:
                 logger.error(f"Failed to publish data to {topic}: {e}")
+                raise e
 
     def subscribe(self, topic: ProcessingTopic | List[ProcessingTopic], subscriber_id: str, queue_size=100) -> Queue:
         """Subscribe to one or more topics and receive a dedicated queue for receiving data.