diff --git a/runnable/entrypoints.py b/runnable/entrypoints.py index 02cdc144..5d02492e 100644 --- a/runnable/entrypoints.py +++ b/runnable/entrypoints.py @@ -16,6 +16,9 @@ logger = logging.getLogger(defaults.LOGGER_NAME) +print("") # removes the buffer print + + def get_default_configs() -> RunnableConfig: """ User can provide extensions as part of their code base, runnable-config.yaml provides the place to put them. diff --git a/runnable/tasks.py b/runnable/tasks.py index 8e0d5e16..720c285e 100644 --- a/runnable/tasks.py +++ b/runnable/tasks.py @@ -156,19 +156,6 @@ def execution_context( params = self.resolve_unreduced_parameters(map_variable=map_variable) logger.info(f"Parameters available for the execution: {params}") - for param_name, param in params.items(): - # Any access to unreduced param should be replaced. - # The replacement is the context param - # It is possible that the unreduced param is not created as no upstream step - # has created it yet. - if param.reduced is False: - context_param = param_name - for _, v in map_variable.items(): # type: ignore - context_param = f"{v}_{context_param}" - - if context_param in params: - params[param_name].value = params[context_param].value - task_console.log("Parameters available for the execution:") task_console.log(params)