support new pcodec delta_spec

Author: slevang

docs/release.rst

@@ -11,6 +11,10 @@ Release notes
 Unreleased
 ----------
 
+Fixes
+~~~~~
+* Add support for pcodec v0.3.
+  By :user:`Sam Levang <slevang>`, :issue:`623`
 
 .. _release_0.14.0:
 

numcodecs/pcodec.py

@@ -8,6 +8,11 @@
 except ImportError:  # pragma: no cover
     standalone = None
 
+# backwards compatibility for pcodec<0.3.0
+try:
+    from pcodec import DeltaSpec
+except ImportError:  # pragma: no cover
+    DeltaSpec = None
 
 DEFAULT_MAX_PAGE_N = 262144
 
@@ -62,6 +67,15 @@ def __init__(
     def encode(self, buf):
         buf = ensure_contiguous_ndarray(buf)
 
+        if DeltaSpec is not None:
+            if self.delta_encoding_order is None:
+                delta_spec = DeltaSpec.auto()
+            else:
+                delta_spec = DeltaSpec.try_consecutive(self.delta_encoding_order)
+            delta_kwargs = {"delta_spec": delta_spec}
+        else:
+            delta_kwargs = {"delta_encoding_order": self.delta_encoding_order}
+
         match self.mode_spec:
             case 'auto':
                 mode_spec = ModeSpec.auto()
@@ -73,9 +87,9 @@ def encode(self, buf):
 
         config = ChunkConfig(
             compression_level=self.level,
-            delta_encoding_order=self.delta_encoding_order,
             mode_spec=mode_spec,
             paging_spec=paging_spec,
+            **delta_kwargs,
         )
         return standalone.simple_compress(buf, config)
 

numcodecs/tests/test_pcodec.py

@@ -25,6 +25,7 @@
     PCodec(level=9),
     PCodec(mode_spec='classic'),
     PCodec(equal_pages_up_to=300),
+    PCodec(delta_encoding_order=2),
 ]
 
 

pyproject.toml

@@ -68,7 +68,7 @@ zfpy = [
     "numpy<2.0.0",
 ]
 pcodec = [
-    "pcodec>=0.2,<0.3",
+    "pcodec>=0.2",
 ]
 crc32c = [
     "crc32c>=2.7",