Function _build_env_variables

src/execution/executor.py:253–291

(parameter_values, parameters: List[ParameterModel], execution_id)

def _build_env_variables(parameter_values, parameters: List[ParameterModel], execution_id):
    result = {}
    excluded = []
    for param_name, value in parameter_values.items():
        if isinstance(value, list) or (value is None):
            continue

        found_parameters = [p for p in parameters if p.name == param_name]
        if len(found_parameters) != 1:
            continue

        parameter = found_parameters[0]

        if not parameter.pass_as.pass_as_env_variable():
            continue

        env_var = parameter.env_var
        if env_var is None:
            env_var = _to_env_name(param_name)

        if (not env_var) or (env_var in excluded):
            continue

        if env_var in result:
            excluded.append(env_var)
            del result[env_var]
            continue

        if parameter.no_value:
            if (value is not None) and (read_bool(value) == True):
                result[env_var] = 'true'
            continue

        result[env_var] = str(value)

    if 'EXECUTION_ID' not in result:
        result['EXECUTION_ID'] = str(execution_id)

    return result


def _concat_output(output_chunks):