From e801f2d1f859306c6a2b0d66d265753ee9e32a54 Mon Sep 17 00:00:00 2001 From: Alexandre Girard Date: Mon, 13 Jun 2022 17:55:45 -0700 Subject: [PATCH] rename --- ...sian_product_stream_slicer.py => product_stream_slicer.py} | 2 +- ...product_stream_slicer.py => test_product_stream_slicer.py} | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) rename airbyte-cdk/python/airbyte_cdk/sources/declarative/stream_slicers/{cartesian_product_stream_slicer.py => product_stream_slicer.py} (95%) rename airbyte-cdk/python/unit_tests/sources/declarative/stream_slicers/{test_cartesian_product_stream_slicer.py => test_product_stream_slicer.py} (94%) diff --git a/airbyte-cdk/python/airbyte_cdk/sources/declarative/stream_slicers/cartesian_product_stream_slicer.py b/airbyte-cdk/python/airbyte_cdk/sources/declarative/stream_slicers/product_stream_slicer.py similarity index 95% rename from airbyte-cdk/python/airbyte_cdk/sources/declarative/stream_slicers/cartesian_product_stream_slicer.py rename to airbyte-cdk/python/airbyte_cdk/sources/declarative/stream_slicers/product_stream_slicer.py index ad0f6f10e942..8254aea1c850 100644 --- a/airbyte-cdk/python/airbyte_cdk/sources/declarative/stream_slicers/cartesian_product_stream_slicer.py +++ b/airbyte-cdk/python/airbyte_cdk/sources/declarative/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/airbyte-cdk/python/unit_tests/sources/declarative/stream_slicers/test_cartesian_product_stream_slicer.py b/airbyte-cdk/python/unit_tests/sources/declarative/stream_slicers/test_product_stream_slicer.py similarity index 94% rename from airbyte-cdk/python/unit_tests/sources/declarative/stream_slicers/test_cartesian_product_stream_slicer.py rename to airbyte-cdk/python/unit_tests/sources/declarative/stream_slicers/test_product_stream_slicer.py index 29cc1d58eadb..e36aa345b00a 100644 --- a/airbyte-cdk/python/unit_tests/sources/declarative/stream_slicers/test_cartesian_product_stream_slicer.py +++ b/airbyte-cdk/python/unit_tests/sources/declarative/stream_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