feat: updates arg name for zarr path

AllenNeuralDynamics · Mar 18, 2024 · 639aafe · 639aafe
1 parent 9302f31
commit 639aafe
Show file tree

Hide file tree

Showing 5 changed files with 19 additions and 22 deletions.
diff --git a/src/aind_data_transformation/ephys/ephys_job.py b/src/aind_data_transformation/ephys/ephys_job.py
@@ -356,7 +356,7 @@ def _compress_and_write_block(
                 )
             _ = rec.save(
                 format=output_format,
-                zarr_path=zarr_path,
+                folder=zarr_path,
                 compressor=compressor,
                 **job_kwargs,
             )

diff --git a/tests/resources/v0.6.x_neuropixels_multiexp_multistream/Videos/a_video_file.avi b/tests/resources/v0.6.x_neuropixels_multiexp_multistream/Videos/a_video_file.avi
diff --git a/tests/resources/v0.6.x_neuropixels_multiexp_multistream/Videos/another_video_file.avi b/tests/resources/v0.6.x_neuropixels_multiexp_multistream/Videos/another_video_file.avi
diff --git a/tests/resources/v0.6.x_neuropixels_multiexp_multistream/Videos/video_ref.csv b/tests/resources/v0.6.x_neuropixels_multiexp_multistream/Videos/video_ref.csv
diff --git a/tests/test_ephys_job.py b/tests/test_ephys_job.py
@@ -521,7 +521,7 @@ def test_compress_and_write_scaled_blocks(
             [
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -541,7 +541,7 @@ def test_compress_and_write_scaled_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -561,7 +561,7 @@ def test_compress_and_write_scaled_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -585,7 +585,7 @@ def test_compress_and_write_scaled_blocks(
             [
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -605,7 +605,7 @@ def test_compress_and_write_scaled_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -625,7 +625,7 @@ def test_compress_and_write_scaled_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -645,7 +645,7 @@ def test_compress_and_write_scaled_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -665,7 +665,7 @@ def test_compress_and_write_scaled_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -685,7 +685,7 @@ def test_compress_and_write_scaled_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -741,7 +741,7 @@ def test_compress_and_write_read_blocks(
             [
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -761,7 +761,7 @@ def test_compress_and_write_read_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -781,7 +781,7 @@ def test_compress_and_write_read_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -801,7 +801,7 @@ def test_compress_and_write_read_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -821,7 +821,7 @@ def test_compress_and_write_read_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -841,7 +841,7 @@ def test_compress_and_write_read_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -861,7 +861,7 @@ def test_compress_and_write_read_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -881,7 +881,7 @@ def test_compress_and_write_read_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (
@@ -901,7 +901,7 @@ def test_compress_and_write_read_blocks(
                 ),
                 call(
                     format="zarr",
-                    zarr_path=(
+                    folder=(
                         Path("output_dir")
                         / "compressed"
                         / (