commit 7b3ae04dd9e38340911f014dea6ff36c967f4935
author garciadeblas <gerardo.garciadeblas@telefonica.com> Tue Dec 09 19:19:44 2025 +0100
committer garciadeblas <gerardo.garciadeblas@telefonica.com> Tue Dec 09 19:49:19 2025 +0100
tree 2367a7681f55e65c650051585694ff49a4caa671
parent 3bc0902f5d028462e8ad4ff4d13e7a3eb14ad666

Minor changes in pyproject.toml and tox.ini

Change-Id: I63451168d2cc3170f2b0d469775c3c54dded9313
Signed-off-by: garciadeblas <gerardo.garciadeblas@telefonica.com>

src/osm_common/msgkafka.py

diff --git a/src/osm_common/msgkafka.py b/src/osm_common/msgkafka.py
index 02b8241..516251c 100644
--- a/src/osm_common/msgkafka.py
+++ b/src/osm_common/msgkafka.py
@@ -121,7 +121,7 @@
         aiocallback=None,
         group_id=None,
         from_beginning=None,
-        **kwargs
+        **kwargs,
     ):
         """
         Asyncio read from one or several topics.
@@ -159,14 +159,14 @@
                         message.topic,
                         yaml.safe_load(message.key),
                         yaml.safe_load(message.value),
-                        **kwargs
+                        **kwargs,
                     )
                 elif aiocallback:
                     await aiocallback(
                         message.topic,
                         yaml.safe_load(message.key),
                         yaml.safe_load(message.value),
-                        **kwargs
+                        **kwargs,
                     )
                 else:
                     return (