Skip to content

Commit 564e6a5

Browse files
author
Alan Christie
committed
fix: Support for dirsGlob
1 parent 515b7f5 commit 564e6a5

File tree

1 file changed

+14
-0
lines changed

1 file changed

+14
-0
lines changed

workflow/workflow_engine.py

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -101,6 +101,12 @@
101101
_LOGGER.setLevel(logging.INFO)
102102
_LOGGER.addHandler(logging.StreamHandler(sys.stdout))
103103

104+
# The variable expected to bu used by "combiner" steps,
105+
# those that take inputs from multiple prior steps.
106+
# This variable gets set to the engine's 'instance-link-glob'
107+
# pre-defined variable
108+
_INSTANCE_LINK_GLOB_VARIABLE: str = "dirsGlob"
109+
104110

105111
@dataclass
106112
class StepPreparationResponse:
@@ -664,6 +670,14 @@ def _prepare_step(
664670
value = f"{p_i_dir}/{value}"
665671
prime_variables[connector.out] = value
666672

673+
# Combiner's automatically get the 'instance-link-glob' pre-defined variable.
674+
# It's injected into the step variables as the _INSTANCE_LINK_GLOB_VARIABLE,
675+
# which the combiner is expected to handle.
676+
if we_are_a_combiner:
677+
prime_variables[_INSTANCE_LINK_GLOB_VARIABLE] = self._predefined_variables[
678+
"instance-link-glob"
679+
]
680+
667681
# Our step's prime variables are now set.
668682

669683
# Before we return these to the caller do we have enough

0 commit comments

Comments
 (0)