diff --git a/cylc/flow/scripts/trigger.py b/cylc/flow/scripts/trigger.py index 3e4a3da96f7..9818bae329a 100755 --- a/cylc/flow/scripts/trigger.py +++ b/cylc/flow/scripts/trigger.py @@ -140,7 +140,6 @@ def _validate(options): async def run(options: 'Values', workflow_id: str, *tokens_list): pclient = get_client(workflow_id, timeout=options.comms_timeout) - mutation_kwargs = { 'request_string': MUTATION, 'variables': { @@ -165,7 +164,6 @@ def main(parser: COP, options: 'Values', *ids: str): if options.flow is None: options.flow = [FLOW_ALL] # default to all active flows _validate(options) - call_multi( partial(run, options), *ids, diff --git a/tests/integration/test_examples.py b/tests/integration/test_examples.py index da8b156503d..005ab551982 100644 --- a/tests/integration/test_examples.py +++ b/tests/integration/test_examples.py @@ -260,6 +260,7 @@ async def test_reflog(flow, scheduler, run, reflog, complete): async with run(schd): triggers = reflog(schd) # Note: add flow_nums=True to capture flows + breakpoint() await complete(schd) assert triggers == {