Skip to content
Snippets Groups Projects
Commit f1608599 authored by Nicolas Dandrimont's avatar Nicolas Dandrimont
Browse files

Lower logging level in the rabbitmq server backend for messages

parent 49eb0290
No related branches found
No related tags found
No related merge requests found
......@@ -298,7 +298,7 @@ class ProvenanceStorageRabbitMQWorker(multiprocessing.Process):
properties: pika.spec.BasicProperties,
body: bytes,
) -> None:
LOGGER.info(
LOGGER.debug(
"Received message # %s from %s: %s",
deliver.delivery_tag,
properties.app_id,
......@@ -311,7 +311,7 @@ class ProvenanceStorageRabbitMQWorker(multiprocessing.Process):
self._request_queues[deliver.routing_key].put(
(tuple(item), (properties.correlation_id, properties.reply_to))
)
LOGGER.info("Acknowledging message %s", deliver.delivery_tag)
LOGGER.debug("Acknowledging message %s", deliver.delivery_tag)
channel.basic_ack(delivery_tag=deliver.delivery_tag)
def stop_consuming(self) -> None:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment