@@ -58,7 +58,7 @@ def apply_async_mock(fn, args, *extra_args, **kwargs):
5858 },
5959 ),
6060 (
61- {"pyzstd " },
61+ {"compression.zstd " },
6262 {
6363 "PRECOMPRESS_GZIP" : True ,
6464 "PRECOMPRESS_BROTLI" : False ,
@@ -67,7 +67,7 @@ def apply_async_mock(fn, args, *extra_args, **kwargs):
6767 },
6868 ),
6969 (
70- {"brotli" , "zopfli" , "pyzstd " },
70+ {"brotli" , "zopfli" , "compression.zstd " },
7171 {
7272 "PRECOMPRESS_GZIP" : False ,
7373 "PRECOMPRESS_BROTLI" : True ,
@@ -83,7 +83,7 @@ def test_get_settings_compression_support(installed_modules, expected_settings):
8383
8484 patches = [
8585 patch (f"pelican.plugins.precompress.{ module } " , module in installed_modules )
86- for module in {"brotli" , "zopfli" , "pyzstd " }
86+ for module in {"brotli" , "zopfli" , "compression.zstd " }
8787 ]
8888 [patch_ .start () for patch_ in patches ]
8989
@@ -111,7 +111,7 @@ def test_get_settings_compression_validation():
111111 patches = [
112112 patch ("pelican.plugins.precompress.brotli" , None ),
113113 patch ("pelican.plugins.precompress.zopfli" , None ),
114- patch ("pelican.plugins.precompress.pyzstd " , None ),
114+ patch ("pelican.plugins.precompress.compression.zstd " , None ),
115115 patch ("pelican.plugins.precompress.log" , log ),
116116 ]
117117 [patch_ .start () for patch_ in patches ]
@@ -192,14 +192,14 @@ def test_compress_with_gzip_exception():
192192 pp .compress_with_gzip (b"" )
193193
194194
195+ @pytest .mark .skipif (pp .compression .zstd is None , reason = "zstandard is unavailable" )
195196def test_compress_with_zstandard ():
196- zstandard = pytest .importorskip ("pyzstd" )
197197 data = b"a" * 100
198- assert zstandard .decompress (pp .compress_with_zstandard (data )) == data
198+ assert pp . compression . zstd .decompress (pp .compress_with_zstandard (data )) == data
199199
200200
201+ @pytest .mark .skipif (pp .compression .zstd is None , reason = "zstandard is unavailable" )
201202def test_compress_with_zstandard_error ():
202- pytest .importorskip ("pyzstd" )
203203 with pytest .raises (pp .FileSizeIncrease ):
204204 pp .compress_with_zstandard (b"" )
205205
@@ -334,8 +334,8 @@ def test_compress_files_overwrite_gz(fs, multiprocessing):
334334 assert gzip .decompress (file .read ()) == b"a" * 100
335335
336336
337+ @pytest .mark .skipif (pp .compression .zstd is None , reason = "zstandard is unavailable" )
337338def test_compress_files_overwrite_zst (fs , multiprocessing ):
338- zstandard = pytest .importorskip ("pyzstd" )
339339 with open ("/test.txt" , "wb" ) as file :
340340 file .write (b"a" * 100 )
341341 with open ("/test.txt.zst" , "wb" ) as file :
@@ -353,7 +353,7 @@ def test_compress_files_overwrite_zst(fs, multiprocessing):
353353 pp .compress_files (instance )
354354 log .warning .assert_called_once ()
355355 with pathlib .Path ("/test.txt.zst" ).open ("rb" ) as file :
356- assert zstandard .decompress (file .read ()) == b"a" * 100
356+ assert pp . compression . zstd .decompress (file .read ()) == b"a" * 100
357357
358358
359359def test_compress_files_file_size_increase (fs , multiprocessing ):
@@ -421,10 +421,10 @@ def test_compress_files_overwrite_erase_existing_file(fs, multiprocessing):
421421 assert not pathlib .Path ("/test.txt.gz" ).exists ()
422422
423423
424+ @pytest .mark .skipif (pp .compression .zstd is None , reason = "zstandard is unavailable" )
424425def test_compress_files_success_all_algorithms (fs , multiprocessing ):
425426 pytest .importorskip ("brotli" )
426427 pytest .importorskip ("zopfli" )
427- pytest .importorskip ("pyzstd" )
428428 with open ("/test.txt" , "wb" ) as file :
429429 file .write (b"a" * 100 )
430430 instance = Mock ()
0 commit comments