diff --git a/tests/components/test_streams_app.py b/tests/components/test_streams_app.py index f0414ebb5..78ae2dab3 100644 --- a/tests/components/test_streams_app.py +++ b/tests/components/test_streams_app.py @@ -196,11 +196,7 @@ def test_cleaner_helm_name_override(self, streams_app: StreamsApp): == STREAMS_APP_CLEAN_HELM_NAME_OVERRIDE ) - def test_set_topics( - self, - config: KpopsConfig, - handlers: ComponentHandlers, - ): + def test_set_topics(self, config: KpopsConfig, handlers: ComponentHandlers): streams_app = StreamsApp( name=STREAMS_APP_NAME, config=config, @@ -249,9 +245,7 @@ def test_set_topics( assert "extraInputPatterns" in streams_config def test_no_empty_input_topic( - self, - config: KpopsConfig, - handlers: ComponentHandlers, + self, config: KpopsConfig, handlers: ComponentHandlers ): streams_app = StreamsApp( name=STREAMS_APP_NAME, @@ -281,11 +275,7 @@ def test_no_empty_input_topic( assert "inputPattern" in streams_config assert "extraInputPatterns" not in streams_config - def test_should_validate( - self, - config: KpopsConfig, - handlers: ComponentHandlers, - ): + def test_should_validate(self, config: KpopsConfig, handlers: ComponentHandlers): # An exception should be raised when both role and type are defined and type is input with pytest.raises( ValueError, match="Define role only if `type` is `pattern` or `None`" @@ -335,9 +325,7 @@ def test_should_validate( ) def test_set_streams_output_from_to( - self, - config: KpopsConfig, - handlers: ComponentHandlers, + self, config: KpopsConfig, handlers: ComponentHandlers ): streams_app = StreamsApp( name=STREAMS_APP_NAME, @@ -380,9 +368,7 @@ def test_set_streams_output_from_to( ) def test_weave_inputs_from_prev_component( - self, - config: KpopsConfig, - handlers: ComponentHandlers, + self, config: KpopsConfig, handlers: ComponentHandlers ): streams_app = StreamsApp( name=STREAMS_APP_NAME, @@ -735,9 +721,7 @@ async def test_should_deploy_clean_up_job_with_image_tag_in_cluster( @pytest.mark.asyncio() async def test_get_input_output_topics( - self, - config: KpopsConfig, - handlers: ComponentHandlers, + self, config: KpopsConfig, handlers: ComponentHandlers ): streams_app = StreamsApp( name="my-app", @@ -885,7 +869,6 @@ async def test_stateful_clean_with_dry_run_true( caplog: pytest.LogCaptureFixture, ): caplog.set_level(logging.INFO) - cleaner = stateful_streams_app._cleaner assert isinstance(cleaner, StreamsAppCleaner)