Merge branch 'main' into andrew/revise_stderr

pyproject.toml

@@ -32,6 +32,7 @@ dev = [
   "pytest-xdist",
   "async-timeout",
   "poethepoet>=0.31.1",
+  "numpy"
 ]
 
 [project.scripts]

tests/test_serializer.py

@@ -1,5 +1,7 @@
 from datetime import datetime
 
+import numpy as np
+
 from choreographer.pipe import Pipe
 
 data = [1, 2.00, 3, float("nan"), float("inf"), float("-inf"), datetime(1970, 1, 1)]
@@ -13,6 +15,11 @@ def test_de_serialize():
     obj = pipe.deserialize(message[:-1]) # split out \0
     for o, t in zip(obj, converted_type):
         assert isinstance(o, t)
+    message_np = pipe.serialize(np.array(data))
+    assert message_np == expected_message
+    obj_np = pipe.deserialize(message_np[:-1]) # split out \0
+    for o, t in zip(obj_np, converted_type):
+        assert isinstance(o, t)
 
 
 # TODO: Not sure if this all the data we have to worry about: