diff --git a/requirements_dev.txt b/requirements_dev.txt index 2a860937..d6c04159 100644 --- a/requirements_dev.txt +++ b/requirements_dev.txt @@ -2,7 +2,7 @@ bidict==0.23.1 pika==1.3.2 prometheus_client==0.21.0 pytest==9.0.3 -pytest-cov==6.0.0 +pytest-cov==7.1.0 pytest-mock==3.14.0 pytest-timeout==2.3.1 stomp-py==8.1.2 diff --git a/src/workflows/transport/middleware/__init__.py b/src/workflows/transport/middleware/__init__.py index 1ace0ff0..a8d8f76b 100644 --- a/src/workflows/transport/middleware/__init__.py +++ b/src/workflows/transport/middleware/__init__.py @@ -236,8 +236,10 @@ def wrap(f: Callable): @functools.wraps(f) def wrapper(self, *args, **kwargs): return functools.reduce( - lambda call_next, m: lambda *args, **kwargs: getattr(m, f.__name__)( - call_next, *args, **kwargs + lambda call_next, m: ( + lambda *args, **kwargs: getattr(m, f.__name__)( + call_next, *args, **kwargs + ) ), reversed(self.middleware), lambda *args, **kwargs: f(self, *args, **kwargs), diff --git a/tests/services/test_common_service.py b/tests/services/test_common_service.py index 313f57fa..91427a97 100644 --- a/tests/services/test_common_service.py +++ b/tests/services/test_common_service.py @@ -373,8 +373,10 @@ def initializing(): # Traceback should have been sent to log log_msgs = list( filter( - lambda c: c[0][0] == {"band": "log", "payload": mock.ANY} - and c[0][0]["payload"].levelname == "CRITICAL", + lambda c: ( + c[0][0] == {"band": "log", "payload": mock.ANY} + and c[0][0]["payload"].levelname == "CRITICAL" + ), fe_pipe.send.call_args_list, ) )