Skip to content

Commit

Permalink
allow fam triggers
Browse files Browse the repository at this point in the history
  • Loading branch information
wxtim committed Feb 6, 2025
1 parent bdadd4b commit c162aaf
Showing 1 changed file with 4 additions and 9 deletions.
13 changes: 4 additions & 9 deletions cylc/flow/config.py
Original file line number Diff line number Diff line change
Expand Up @@ -2288,25 +2288,20 @@ def check_outputs(self, terminals: Iterable[str]) -> None:
Raises: WorkflowConfigError if a custom output is not defined.
"""
from cylc.flow.task_qualifiers import TASK_QUALIFIERS
terminal_outputs = []
for terminal in terminals:
if ':' in terminal:
task = re.findall(TaskID.NAME_RE, terminal)[0]
qualifier = re.findall(GraphParser._RE_QUAL, terminal)
if qualifier:
qualifier_str = qualifier[0].strip(':')
else:
qualifier_str = ''
if qualifier_str in ALT_QUALIFIERS:
qualifier_str = ALT_QUALIFIERS[qualifier_str]
terminal_outputs.append((task, qualifier_str))
if qualifier_str and qualifier_str not in TASK_QUALIFIERS:
terminal_outputs.append((task, qualifier_str))

for task, output in terminal_outputs:
registered_outputs = self.cfg['runtime'][task]['outputs']
if (
not TaskOutputs.is_valid_std_name(output)
and output not in registered_outputs
):
if output not in registered_outputs:
raise WorkflowConfigError(
f"Undefined custom output: {task}:{output}"
)
Expand Down

0 comments on commit c162aaf

Please sign in to comment.