Add --create-namespace option to helm (#91)

FIxes #90
bakdata · Feb 3, 2023 · 8a2d1d6 · 8a2d1d6
1 parent e1c7de6
commit 8a2d1d6
Show file tree

Hide file tree

Showing 8 changed files with 15 additions and 3 deletions.
diff --git a/.github/workflows/ci.yaml b/.github/workflows/ci.yaml
@@ -50,6 +50,6 @@ jobs:
   publish:
     name: Publish
     needs: [test]
-    uses: ./.github/workflows/publish-dev.yaml
+    uses: ./.github/workflows/publish-test-pypi.yaml
     secrets:
       test-pypi-token: ${{ secrets.TEST_PYPI_TOKEN }}
diff --git a/kpops/cli/pipeline_config.py b/kpops/cli/pipeline_config.py
@@ -68,6 +68,7 @@ class PipelineConfig(BaseSettings):
         description="Pipeline prefix that will prefix every component name. If you wish to not have any prefix you can specify an empty string.",
     )
 
+    create_namespace: bool = Field(default=False)
     helm_config: HelmConfig = Field(default=HelmConfig())
     helm_diff_config: HelmDiffConfig = Field(default=HelmDiffConfig())
 

diff --git a/kpops/component_handlers/helm_wrapper/helm.py b/kpops/component_handlers/helm_wrapper/helm.py
@@ -178,6 +178,8 @@ def __enrich_upgrade_install_command(
         dry_run: bool,
         helm_command_config: HelmUpgradeInstallFlags,
     ) -> list[str]:
+        if helm_command_config.create_namespace:
+            command.append("--create-namespace")
         if dry_run:
             command.append("--dry-run")
         if helm_command_config.force:

diff --git a/kpops/component_handlers/helm_wrapper/model.py b/kpops/component_handlers/helm_wrapper/model.py
@@ -40,6 +40,7 @@ class HelmConfig:
 
 @dataclass
 class HelmUpgradeInstallFlags:
+    create_namespace: bool = False
     force: bool = False
     repo_auth_flags: RepoAuthFlags = field(default_factory=RepoAuthFlags)
     timeout: str = "5m0s"

diff --git a/kpops/components/base_components/kafka_app.py b/kpops/components/base_components/kafka_app.py
@@ -136,6 +136,7 @@ def __install_clean_up_job(
             self.namespace,
             values,
             HelmUpgradeInstallFlags(
+                create_namespace=self.config.create_namespace,
                 version=self.version,
                 wait=True,
                 wait_for_jobs=True,

diff --git a/kpops/components/base_components/kafka_connect.py b/kpops/components/base_components/kafka_connect.py
@@ -176,7 +176,10 @@ def __install_connect_resetter(
             chart=self.kafka_connect_resetter_chart,
             dry_run=dry_run,
             flags=HelmUpgradeInstallFlags(
-                version=self.version, wait_for_jobs=True, wait=True
+                create_namespace=self.config.create_namespace,
+                version=self.version,
+                wait_for_jobs=True,
+                wait=True,
             ),
             values={
                 **KafkaConnectResetterValues(

diff --git a/kpops/components/base_components/kubernetes_app.py b/kpops/components/base_components/kubernetes_app.py
@@ -78,7 +78,9 @@ def deploy(self, dry_run: bool) -> None:
             dry_run,
             self.namespace,
             self.to_helm_values(),
-            HelmUpgradeInstallFlags(version=self.version),
+            HelmUpgradeInstallFlags(
+                create_namespace=self.config.create_namespace, version=self.version
+            ),
         )
         if dry_run and self.helm_diff.config.enable:
             self.print_helm_diff(stdout)

diff --git a/tests/component_handlers/helm_wrapper/test_helm_wrapper.py b/tests/component_handlers/helm_wrapper/test_helm_wrapper.py
@@ -138,6 +138,7 @@ def test_should_call_run_command_method_when_helm_install_with_non_defaults(
             dry_run=True,
             values={"commandLine": "test"},
             flags=HelmUpgradeInstallFlags(
+                create_namespace=True,
                 force=True,
                 timeout="120s",
                 wait=True,
@@ -157,6 +158,7 @@ def test_should_call_run_command_method_when_helm_install_with_non_defaults(
                 "test-namespace",
                 "--values",
                 "values.yaml",
+                "--create-namespace",
                 "--dry-run",
                 "--force",
                 "--wait",