global: format with ruff

Author: indygreg

bench.py

@@ -81,7 +81,7 @@ def bench(
     def wrapper(fn):
         if not fn.__name__.startswith(("compress_", "decompress_")):
             raise ValueError(
-                "benchmark function must begin with " "compress_ or decompress_"
+                "benchmark function must begin with compress_ or decompress_"
             )
 
         fn.mode = mode
@@ -789,18 +789,17 @@ def bench_content_dict_decompression(chunks, total_size, zparams):
     group.add_argument(
         "--stream",
         action="store_true",
-        help="Feed each input into a stream and emit " "flushed blocks",
+        help="Feed each input into a stream and emit flushed blocks",
     )
     group.add_argument(
         "--content-dict",
         action="store_true",
-        help="Compress each input using the previous as a "
-        "content dictionary",
+        help="Compress each input using the previous as a content dictionary",
     )
     group.add_argument(
         "--discrete-dict",
         action="store_true",
-        help="Compress each input independently with a " "dictionary",
+        help="Compress each input independently with a dictionary",
     )
 
     group = parser.add_argument_group("Benchmark Selection")
@@ -854,7 +853,7 @@ def bench_content_dict_decompression(chunks, total_size, zparams):
     group.add_argument(
         "--compress-threads",
         type=int,
-        help="Use multi-threaded compression with this many " "threads",
+        help="Use multi-threaded compression with this many threads",
     )
     group.add_argument(
         "--batch-threads",
@@ -885,7 +884,7 @@ def bench_content_dict_decompression(chunks, total_size, zparams):
     group.add_argument(
         "--dict-sample-limit",
         type=int,
-        help="limit how many samples are fed into dictionary " "training",
+        help="limit how many samples are fed into dictionary training",
     )
     group.add_argument(
         "--chunk-encoding",
@@ -897,7 +896,7 @@ def bench_content_dict_decompression(chunks, total_size, zparams):
     group.add_argument(
         "--split-input-size",
         type=int,
-        help="Split inputs into chunks so they are at most this " "many bytes",
+        help="Split inputs into chunks so they are at most this many bytes",
     )
 
     parser.add_argument("path", metavar="PATH", nargs="+")

make_cffi.py

@@ -23,7 +23,10 @@
 ]
 
 # Headers whose preprocessed output will be fed into cdef().
-HEADERS = [os.path.join(HERE, "zstd", p) for p in ("zstd_errors.h", "zstd.h", "zdict.h")]
+HEADERS = [
+    os.path.join(HERE, "zstd", p)
+    for p in ("zstd_errors.h", "zstd.h", "zdict.h")
+]
 
 INCLUDE_DIRS = [
     os.path.join(HERE, "zstd"),
@@ -95,7 +98,7 @@ def preprocess(path):
 
             # There's a naked `static` before the declaration of ZSTD_customMem that
             # confuses the cffi parser. Strip it.
-            if line == b'static\n':
+            if line == b"static\n":
                 continue
 
             # The preprocessor environment on Windows doesn't define include
@@ -164,6 +167,7 @@ def normalize_output(output):
 
     return b"\n".join(lines)
 
+
 # musl 1.1 doesn't define qsort_r. We need to force using the C90
 # variant.
 define_macros = []
@@ -189,7 +193,7 @@ def normalize_output(output):
 """,
     sources=SOURCES,
     include_dirs=INCLUDE_DIRS,
-    define_macros=define_macros
+    define_macros=define_macros,
 )
 
 DEFINE = re.compile(rb"^#define\s+([a-zA-Z0-9_]+)\s+(\S+)")

setup.py

@@ -146,7 +146,7 @@
 
 if not version:
     raise Exception(
-        "could not resolve package version; " "this should never happen"
+        "could not resolve package version; this should never happen"
     )
 
 setup(

tests/test_compressor_compress.py

@@ -198,8 +198,7 @@ def test_multithreaded_dict(self):
 
         self.assertEqual(
             result,
-            b"\x28\xb5\x2f\xfd\x23\x27\x42\xfc\x42\x03\x19\x00\x00"
-            b"\x66\x6f\x6f",
+            b"\x28\xb5\x2f\xfd\x23\x27\x42\xfc\x42\x03\x19\x00\x00\x66\x6f\x6f",
         )
 
     def test_multithreaded_compression_params(self):

tests/test_decompressor.py

@@ -7,14 +7,14 @@ class TestFrameHeaderSize(unittest.TestCase):
     def test_empty(self):
         with self.assertRaisesRegex(
             zstd.ZstdError,
-            "could not determine frame header size: Src size " "is incorrect",
+            "could not determine frame header size: Src size is incorrect",
         ):
             zstd.frame_header_size(b"")
 
     def test_too_small(self):
         with self.assertRaisesRegex(
             zstd.ZstdError,
-            "could not determine frame header size: Src size " "is incorrect",
+            "could not determine frame header size: Src size is incorrect",
         ):
             zstd.frame_header_size(b"foob")
 

zstandard/__init__.pyi

@@ -450,7 +450,9 @@ class FrameParameters(object):
 def estimate_decompression_context_size() -> int: ...
 def frame_content_size(data: ByteString) -> int: ...
 def frame_header_size(data: ByteString) -> int: ...
-def get_frame_parameters(data: ByteString, format: Optional[int] = None) -> FrameParameters: ...
+def get_frame_parameters(
+    data: ByteString, format: Optional[int] = None
+) -> FrameParameters: ...
 def train_dictionary(
     dict_size: int,
     samples: list[ByteString],