From d70af64cda801e88e39aa2eac5de90159d116101 Mon Sep 17 00:00:00 2001 From: Nathan Freeman Date: Fri, 5 Jan 2024 14:03:43 -0600 Subject: [PATCH] fix bug in envmapper --- src/engine/src/core/mappers/EnvMapper.py | 5 +---- src/engine/src/core/workflows/WorkflowExecutor.py | 1 - 2 files changed, 1 insertion(+), 5 deletions(-) diff --git a/src/engine/src/core/mappers/EnvMapper.py b/src/engine/src/core/mappers/EnvMapper.py index 8acf1a6f..8e5fe820 100644 --- a/src/engine/src/core/mappers/EnvMapper.py +++ b/src/engine/src/core/mappers/EnvMapper.py @@ -6,9 +6,6 @@ def __init__(self, dao: WorkflowExecutorStateDAO): self._dao = dao def get_value_by_key(self, key): - print("ENVMAPPER") - print("KEY", key) - print("KEY ON ENV", self._dao.get_state().ctx.env.get(key)) - env = self._dao.get_state().ctx.env.get(key).value + env = self._dao.get_state().ctx.env.get(key, None) if env == None: return None return env.value \ No newline at end of file diff --git a/src/engine/src/core/workflows/WorkflowExecutor.py b/src/engine/src/core/workflows/WorkflowExecutor.py index 05e056bf..09e4a9eb 100644 --- a/src/engine/src/core/workflows/WorkflowExecutor.py +++ b/src/engine/src/core/workflows/WorkflowExecutor.py @@ -627,7 +627,6 @@ def _prepare_pipeline_fs(self): env_var_value_file_repo = self.container.load("EnvVarValueFileRepository") env_repo = self.container.load("EnvRepository") for key in self.state.ctx.env: - print("KEY", key) env_var_value_file_repo.save( self.state.ctx.pipeline.env_dir + key, env_repo.get_value_by_key(key)