Implement group trigger.

Author: hjoliver

cylc/flow/flow_mgr.py

@@ -160,7 +160,7 @@ def get_flow_num(
 
         if flow_num in self.flows:
             if meta is not None:
-                LOG.warning(
+                LOG.debug(
                     f'Ignoring flow metadata "{meta}":'
                     f' {flow_num} is not a new flow'
                 )

cylc/flow/prerequisite.py

@@ -123,6 +123,13 @@ def __init__(self, point: 'PointBase'):
         # * `False` (prerequisite unsatisfied).
         self._cached_satisfied: Optional[bool] = None
 
+    def dump(self):
+        print(f"POINT {self.point}")
+        for k, v in self._satisfied.items():
+            print(f"_SAT: {k}, {v}")
+        print(f"COND: {self.conditional_expression}")
+        print(f"ALL SAT: {self._all_satisfied}")
+
     def instantaneous_hash(self) -> int:
         """Generate a hash of this prerequisite in its current state.
 

cylc/flow/scheduler.py

@@ -1546,10 +1546,14 @@ def start_job_submission(self, itasks: 'Iterable[TaskProxy]') -> bool:
                 flow = ','.join(str(i) for i in itask.flow_nums)
             else:
                 flow = FLOW_NONE
-            log(
-                f"{itask.identity} -triggered off "
-                f"{itask.state.get_resolved_dependencies()} in flow {flow}"
-            )
+            if itask.is_manual_submit:
+                off = f"[] in flow {flow}"
+            else:
+                off = (
+                    f"{itask.state.get_resolved_dependencies()}"
+                    f" in flow {flow}"
+                )
+            log(f"{itask.identity} -triggered off {off}")
 
         # one or more tasks were passed through the submission pipeline
         return True

cylc/flow/task_job_mgr.py

@@ -469,7 +469,7 @@ def submit_livelike_task_jobs(
                     'platform_name': itask.platform['name'],
                     'job_runner_name': itask.summary['job_runner_name'],
                 })
-
+                # reset the is_manual_submit flag in case of retries
                 itask.is_manual_submit = False
 
             if ri_map[install_target] == REMOTE_FILE_INSTALL_255: