fix(pipeline-generator): clear env on load YAML (#628)

Author: disrupted

kpops/pipeline/__init__.py

@@ -246,6 +246,7 @@ def load_yaml(self, path: Path, environment: str | None) -> Pipeline:
         :raises TypeError: The env-specific pipeline definition should contain a list of components
         :returns: Initialized pipeline object
         """
+        ENV.clear()
         PipelineGenerator.set_pipeline_name_env_vars(
             self.config.pipeline_base_dir, path
         )

tests/pipeline/test_generate.py

@@ -20,6 +20,7 @@
 from kpops.components.streams_bootstrap.streams.streams_app import StreamsApp
 from kpops.const.file_type import PIPELINE_YAML, KpopsFileType
 from kpops.core.exception import ParsingException, ValidationError
+from kpops.utils.environment import ENV
 
 runner = CliRunner()
 
@@ -85,6 +86,12 @@ def test_load_pipeline(self, snapshot: Snapshot):
 
         snapshot.assert_match(result.stdout, PIPELINE_YAML)
 
+    def test_load_yaml_clear_env(self) -> None:
+        kpops.generate(RESOURCE_PATH / "pipeline-folders/pipeline-1/pipeline.yaml")
+        assert ENV["pipeline.name_2"] == "pipeline-1"
+        kpops.generate(RESOURCE_PATH / "first-pipeline" / PIPELINE_YAML)
+        assert "pipeline.name_2" not in ENV
+
     def test_load_pipeline_with_folder_path(self, snapshot: Snapshot):
         result = runner.invoke(
             app,

tests/utils/test_environment.py

@@ -79,3 +79,9 @@ def test_dict_unpacking(environment: Environment):
         "ENVIRONMENT": "here",
         "PYTEST_CURRENT_TEST": ANY,
     }
+
+
+def test_clear(environment: Environment):
+    environment["TEST"] = "test"
+    environment.clear()
+    assert not environment