diff --git a/requirements_dev.txt b/requirements_dev.txt index 2a860937..38286e8f 100644 --- a/requirements_dev.txt +++ b/requirements_dev.txt @@ -1,9 +1,9 @@ bidict==0.23.1 pika==1.3.2 -prometheus_client==0.21.0 +prometheus_client==0.25.0 pytest==9.0.3 -pytest-cov==6.0.0 -pytest-mock==3.14.0 -pytest-timeout==2.3.1 -stomp-py==8.1.2 -websocket-client==1.8.0 \ No newline at end of file +pytest-cov==6.3.0 +pytest-mock==3.15.1 +pytest-timeout==2.4.0 +stomp-py==8.2.0 +websocket-client==1.9.0 \ No newline at end of file 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, ) )