Group trigger

cylc/flow/flow_mgr.py

@@ -127,7 +127,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

@@ -120,6 +120,13 @@
         # * `False` (prerequisite unsatisfied).
         self._all_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

@@ -1275,10 +1275,14 @@ def release_queued_tasks(self) -> 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

@@ -447,7 +447,6 @@ def submit_task_jobs(self, workflow, itasks, curve_auth,
                     'platform_name': itask.platform['name'],
                     'job_runner_name': itask.summary['job_runner_name'],
                 })
-                itask.is_manual_submit = False
 
             if ri_map[install_target] == REMOTE_FILE_INSTALL_255:
                 del ri_map[install_target]
@@ -1103,6 +1102,8 @@ def _submit_task_job_callback(self, workflow, itask, cmd_ctx, line):
             self.task_events_mgr.process_message(
                 itask, CRITICAL, self.task_events_mgr.EVENT_SUBMIT_FAILED,
                 ctx.timestamp)
+        # Submitted, so reset the is_manual submit flag in case of retries.
+        itask.is_manual_submit = False
 
     def _prep_submit_task_job(
         self,