rename

airbytehq · Jun 14, 2022 · e801f2d · e801f2d
1 parent d477d39
commit e801f2d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...licers/cartesian_product_stream_slicer.py → ...e/stream_slicers/product_stream_slicer.py b/...licers/cartesian_product_stream_slicer.py → ...e/stream_slicers/product_stream_slicer.py
@@ -9,7 +9,7 @@
 from airbyte_cdk.sources.declarative.stream_slicers.stream_slicer import StreamSlicer
 
 
-class CartesianProductStreamSlicer(StreamSlicer):
+class ProductStreamSlicer(StreamSlicer):
     """
     Stream slicers that iterates over the cartesian product of input stream slicers
     Given 2 stream slicers with the following slices:

diff --git a/...s/test_cartesian_product_stream_slicer.py → ...eam_slicers/test_product_stream_slicer.py b/...s/test_cartesian_product_stream_slicer.py → ...eam_slicers/test_product_stream_slicer.py
@@ -5,9 +5,9 @@
 import pytest as pytest
 from airbyte_cdk.models import SyncMode
 from airbyte_cdk.sources.declarative.interpolation.interpolated_string import InterpolatedString
-from airbyte_cdk.sources.declarative.stream_slicers.cartesian_product_stream_slicer import CartesianProductStreamSlicer
 from airbyte_cdk.sources.declarative.stream_slicers.datetime_stream_slicer import DatetimeStreamSlicer
 from airbyte_cdk.sources.declarative.stream_slicers.list_stream_slicer import ListStreamSlicer
+from airbyte_cdk.sources.declarative.stream_slicers.product_stream_slicer import ProductStreamSlicer
 
 
 @pytest.mark.parametrize(
@@ -56,6 +56,6 @@
     ],
 )
 def test_substream_slicer(test_name, stream_slicers, expected_slices):
-    slicer = CartesianProductStreamSlicer(stream_slicers)
+    slicer = ProductStreamSlicer(stream_slicers)
     slices = [s for s in slicer.stream_slices(SyncMode.incremental, stream_state=None)]
     assert slices == expected_slices