Skip to content

Commit

Permalink
Update files
Browse files Browse the repository at this point in the history
  • Loading branch information
raminqaf committed Jun 27, 2024
1 parent 1da3176 commit a4227d0
Showing 1 changed file with 0 additions and 14 deletions.
14 changes: 0 additions & 14 deletions tests/components/test_streams_app.py
Original file line number Diff line number Diff line change
Expand Up @@ -137,10 +137,6 @@ def dry_run_handler_mock(self, mocker: MockerFixture) -> MagicMock:
"kpops.components.base_components.helm_app.DryRunHandler"
).return_value

@pytest.fixture()
def empty_helm_get_values(self, mocker: MockerFixture) -> MagicMock:
return mocker.patch.object(HelmApp, "helm_values", return_value=None)

def test_cleaner(self, streams_app: StreamsApp):
cleaner = streams_app._cleaner
assert isinstance(cleaner, StreamsAppCleaner)
Expand Down Expand Up @@ -210,7 +206,6 @@ def test_set_topics(
self,
config: KpopsConfig,
handlers: ComponentHandlers,
empty_helm_get_values: MagicMock,
):
streams_app = StreamsApp(
name=STREAMS_APP_NAME,
Expand Down Expand Up @@ -263,7 +258,6 @@ def test_no_empty_input_topic(
self,
config: KpopsConfig,
handlers: ComponentHandlers,
empty_helm_get_values: MagicMock,
):
streams_app = StreamsApp(
name=STREAMS_APP_NAME,
Expand Down Expand Up @@ -297,7 +291,6 @@ def test_should_validate(
self,
config: KpopsConfig,
handlers: ComponentHandlers,
empty_helm_get_values: MagicMock,
):
# An exception should be raised when both role and type are defined and type is input
with pytest.raises(
Expand Down Expand Up @@ -351,7 +344,6 @@ def test_set_streams_output_from_to(
self,
config: KpopsConfig,
handlers: ComponentHandlers,
empty_helm_get_values: MagicMock,
):
streams_app = StreamsApp(
name=STREAMS_APP_NAME,
Expand Down Expand Up @@ -397,7 +389,6 @@ def test_weave_inputs_from_prev_component(
self,
config: KpopsConfig,
handlers: ComponentHandlers,
empty_helm_get_values: MagicMock,
):
streams_app = StreamsApp(
name=STREAMS_APP_NAME,
Expand Down Expand Up @@ -441,7 +432,6 @@ async def test_deploy_order_when_dry_run_is_false(
self,
config: KpopsConfig,
handlers: ComponentHandlers,
empty_helm_get_values: MagicMock,
mocker: MockerFixture,
):
streams_app = StreamsApp(
Expand Down Expand Up @@ -560,7 +550,6 @@ async def test_destroy(
self,
streams_app: StreamsApp,
mocker: MockerFixture,
empty_helm_get_values: MagicMock,
):
mock_helm_uninstall = mocker.patch.object(streams_app.helm, "uninstall")

Expand Down Expand Up @@ -755,7 +744,6 @@ async def test_get_input_output_topics(
self,
config: KpopsConfig,
handlers: ComponentHandlers,
empty_helm_get_values: MagicMock,
):
streams_app = StreamsApp(
name="my-app",
Expand Down Expand Up @@ -903,8 +891,6 @@ async def test_stateful_clean_with_dry_run_true(
caplog: pytest.LogCaptureFixture,
):
caplog.set_level(logging.INFO)
# actual component
mocker.patch.object(stateful_streams_app, "destroy")

cleaner = stateful_streams_app._cleaner
assert isinstance(cleaner, StreamsAppCleaner)
Expand Down

0 comments on commit a4227d0

Please sign in to comment.