Merge pull request #37 from DataFloz/connector-refactor

fix k8s enviroments
DataFloz · Jul 24, 2023 · 4871fe5 · 4871fe5
2 parents f447175 + 2a4d3fb
commit 4871fe5
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/runner/pipeline_runner/kubernetes_runner.py b/runner/pipeline_runner/kubernetes_runner.py
@@ -48,12 +48,16 @@ def __init__(self, kubernetes_runner_config: PipelineKubernetesRunner):
 
     def rollout(self, pipeline_configuration: PipelineConfig, connector: ConnectorConfig):
         # create a container with environment variables
+
+        envs_dict = pipeline_configuration.as_dict()
+        envs_dict.update(connector.as_dict())
+
         container = client.V1Container(
             name="my-container",
             image="my-image:latest",
             image_pull_policy="Never",
             env=[
-                client.V1EnvVar(name="MY_ENV_VAR", value="my value"),
+                client.V1EnvVar(name=env_key, value=env_value) for env_key, env_value in envs_dict.items()
             ]
         )