@@ -161,6 +161,7 @@ def _remove_matched_tasks(
161161 schd : 'Scheduler' ,
162162 ids : Set [TaskTokens ],
163163 flow_nums : 'FlowNums' ,
164+ warn_unremovable : bool = True ,
164165):
165166 """Remove matched tasks."""
166167 # Mapping of *relative* task IDs to removed flow numbers:
@@ -267,15 +268,14 @@ def _remove_matched_tasks(
267268 )
268269 LOG .info (f"Removed tasks: { ', ' .join (sorted (tasks_str_list ))} " )
269270
270- if not_removed :
271+ if warn_unremovable and not_removed :
271272 fnums_str = (
272273 repr_flow_nums (flow_nums , full = True ) if flow_nums else ''
273274 )
274275 tasks_str = ', ' .join (
275276 sorted (tokens .relative_id for tokens in not_removed )
276277 )
277- # This often does not indicate an error - e.g. for group trigger.
278- LOG .debug (f"Task(s) not removable: { tasks_str } { fnums_str } " )
278+ LOG .warning (f"Task(s) not removable: { tasks_str } { fnums_str } " )
279279
280280 if removed and schd .pool .compute_runahead ():
281281 schd .pool .release_runahead_tasks ()
@@ -806,7 +806,12 @@ def _force_trigger_tasks(
806806 # Remove all inactive and selected active group members.
807807 if flow != [FLOW_NONE ]:
808808 # (No need to remove tasks if triggering with no-flow).
809- _remove_matched_tasks (schd , {* active_to_remove , * inactive }, flow_nums )
809+ _remove_matched_tasks (
810+ schd ,
811+ {* active_to_remove , * inactive },
812+ flow_nums ,
813+ warn_unremovable = False ,
814+ )
810815
811816 # trigger should override the held state, however, in-group tasks may
812817 # have previously been held and active in-group tasks will become
0 commit comments