From 921248b0463f0fd4e0d3feace668571d40d865b2 Mon Sep 17 00:00:00 2001 From: Lancetnik Date: Mon, 22 May 2023 23:05:04 +0300 Subject: [PATCH] fix potential log excheptions --- propan/__about__.py | 2 +- propan/brokers/model/broker_usecase.py | 4 ++-- propan/brokers/rabbit/rabbit_broker.py | 3 ++- 3 files changed, 5 insertions(+), 4 deletions(-) diff --git a/propan/__about__.py b/propan/__about__.py index 4e8c30a4..3e002756 100644 --- a/propan/__about__.py +++ b/propan/__about__.py @@ -1,3 +1,3 @@ """Simple and fast framework to create message brokers based microservices""" -__version__ = "0.1.1.3" +__version__ = "0.1.1.4" diff --git a/propan/brokers/model/broker_usecase.py b/propan/brokers/model/broker_usecase.py index b20d31bb..0de521d7 100644 --- a/propan/brokers/model/broker_usecase.py +++ b/propan/brokers/model/broker_usecase.py @@ -205,7 +205,7 @@ async def wrapper(message: PropanMessage) -> T: log_context = self._get_log_context(message=message, **broker_args) with context.scope("log_context", log_context): - self._log("Received") + self._log("Received", extra=log_context) try: r = await func(message) @@ -213,7 +213,7 @@ async def wrapper(message: PropanMessage) -> T: self._log(repr(e), logging.ERROR) raise e else: - self._log("Processed") + self._log("Processed", extra=log_context) return r return wrapper diff --git a/propan/brokers/rabbit/rabbit_broker.py b/propan/brokers/rabbit/rabbit_broker.py index b44ea956..55b1bf45 100644 --- a/propan/brokers/rabbit/rabbit_broker.py +++ b/propan/brokers/rabbit/rabbit_broker.py @@ -64,7 +64,8 @@ async def _connect( self._channel = await connection.channel() if max_consumers: - self._log(f"Set max consumers to {max_consumers}") + c = self._get_log_context(None, RabbitQueue(""), RabbitExchange("")) + self._log(f"Set max consumers to {max_consumers}", extra=c) await self._channel.set_qos(prefetch_count=int(self._max_consumers)) return connection