🎨 yapf format

Signed-off-by: ff137 <[email protected]>

Author: ff137

nats/js/manager.py

@@ -173,9 +173,7 @@ async def purge_stream(
 
         req = json.dump_bytes(stream_req)
         resp = await self._api_request(
-            f"{self._prefix}.STREAM.PURGE.{name}",
-            req,
-            timeout=self._timeout
+            f"{self._prefix}.STREAM.PURGE.{name}", req, timeout=self._timeout
         )
         return resp["success"]
 
@@ -198,9 +196,7 @@ async def streams_info(self, offset=0) -> List[api.StreamInfo]:
         """
         resp = await self._api_request(
             f"{self._prefix}.STREAM.LIST",
-            json.dump_bytes({
-                "offset": offset
-            }),
+            json.dump_bytes({"offset": offset}),
             timeout=self._timeout,
         )
         streams = []
@@ -216,9 +212,7 @@ async def streams_info_iterator(self,
         """
         resp = await self._api_request(
             f"{self._prefix}.STREAM.LIST",
-            json.dump_bytes({
-                "offset": offset
-            }),
+            json.dump_bytes({"offset": offset}),
             timeout=self._timeout,
         )
 
@@ -283,9 +277,7 @@ async def consumers_info(
         """
         resp = await self._api_request(
             f"{self._prefix}.CONSUMER.LIST.{stream}",
-            b"" if offset is None else json.dump_bytes({
-                "offset": offset
-            }),
+            b"" if offset is None else json.dump_bytes({"offset": offset}),
             timeout=self._timeout,
         )
         consumers = []

tests/test_client.py

@@ -37,7 +37,7 @@ def test_default_connect_command(self):
         nc.options["no_echo"] = False
         got = nc._connect_command()
         expected = f'CONNECT {{"echo": true, "lang": "python3", "pedantic": false, "protocol": 1, "verbose": false, "version": "{__version__}"}}\r\n'
-        
+
         try:
             import orjson
             # If using orjson, expected string is without spaces

tests/test_micro_service.py

@@ -77,13 +77,7 @@ async def add_handler(request: Request):
             svcs.append(svc)
 
         for _ in range(50):
-            await nc.request(
-                "svc.add",
-                json.dump_bytes({
-                    "x": 22,
-                    "y": 11
-                })
-            )
+            await nc.request("svc.add", json.dump_bytes({"x": 22, "y": 11}))
 
         for svc in svcs:
             info = svc.info()