ci(ruff-raise): autofix "RSE"

bakdata · Sep 26, 2023 · 9a8678a · 9a8678a
1 parent b93c3d8
commit 9a8678a
Show file tree

Hide file tree

Showing 6 changed files with 8 additions and 8 deletions.
diff --git a/kpops/cli/main.py b/kpops/cli/main.py
@@ -372,7 +372,7 @@ def clean(
 def version_callback(show_version: bool) -> None:
     if show_version:
         typer.echo(f"KPOps {__version__}")
-        raise typer.Exit()
+        raise typer.Exit
 
 
 @app.callback()

diff --git a/kpops/component_handlers/helm_wrapper/helm.py b/kpops/component_handlers/helm_wrapper/helm.py
@@ -235,7 +235,7 @@ def parse_helm_command_stderr_output(stderr: str) -> None:
         for line in stderr.splitlines():
             lower = line.lower()
             if "release: not found" in lower:
-                raise ReleaseNotFoundException()
+                raise ReleaseNotFoundException
             elif "error" in lower:
                 raise RuntimeError(stderr)
             elif "warning" in lower:

diff --git a/kpops/component_handlers/kafka_connect/connect_wrapper.py b/kpops/component_handlers/kafka_connect/connect_wrapper.py
@@ -79,7 +79,7 @@ def get_connector(self, connector_name: str) -> KafkaConnectResponse:
             return KafkaConnectResponse(**response.json())
         elif response.status_code == httpx.codes.NOT_FOUND:
             log.info(f"The named connector {connector_name} does not exists.")
-            raise ConnectorNotFoundException()
+            raise ConnectorNotFoundException
         elif response.status_code == httpx.codes.CONFLICT:
             log.warning(
                 "Rebalancing in progress while getting a connector... Retrying...",
@@ -170,7 +170,7 @@ def delete_connector(self, connector_name: str) -> None:
             return
         elif response.status_code == httpx.codes.NOT_FOUND:
             log.info(f"The named connector {connector_name} does not exists.")
-            raise ConnectorNotFoundException()
+            raise ConnectorNotFoundException
         elif response.status_code == httpx.codes.CONFLICT:
             log.warning(
                 "Rebalancing in progress while deleting a connector... Retrying...",

diff --git a/kpops/component_handlers/topic/proxy_wrapper.py b/kpops/component_handlers/topic/proxy_wrapper.py
@@ -122,7 +122,7 @@ def get_topic(self, topic_name: str) -> TopicResponse:
         ):
             log.debug(f"Topic {topic_name} not found.")
             log.debug(response.json())
-            raise TopicNotFoundException()
+            raise TopicNotFoundException
 
         raise KafkaRestProxyError(response)
 
@@ -153,7 +153,7 @@ def get_topic_config(self, topic_name: str) -> TopicConfigResponse:
         ):
             log.debug(f"Configs for {topic_name} not found.")
             log.debug(response.json())
-            raise TopicNotFoundException()
+            raise TopicNotFoundException
 
         raise KafkaRestProxyError(response)
 

diff --git a/kpops/components/base_components/kafka_app.py b/kpops/components/base_components/kafka_app.py
@@ -83,7 +83,7 @@ class KafkaApp(KubernetesApp, ABC):
     @property
     def clean_up_helm_chart(self) -> str:
         """Helm chart used to destroy and clean this component."""
-        raise NotImplementedError()
+        raise NotImplementedError
 
     @override
     def deploy(self, dry_run: bool) -> None:

diff --git a/kpops/pipeline_generator/pipeline.py b/kpops/pipeline_generator/pipeline.py
@@ -182,7 +182,7 @@ def parse_components(self, component_list: list[dict]) -> None:
                         msg,
                     ) from ex
                 else:
-                    raise ParsingException() from ex
+                    raise ParsingException from ex
 
     def apply_component(
         self, component_class: type[PipelineComponent], component_data: dict,