Tweak comments.

cylc · Apr 30, 2020 · db3e0b1 · db3e0b1
1 parent 15fe8e4
commit db3e0b1
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 5 deletions.
diff --git a/cylc/flow/network/schema.py b/cylc/flow/network/schema.py
@@ -1409,7 +1409,7 @@ class Arguments(TaskMutation.Arguments):
 class Remove(Mutation, TaskMutation):
     class Meta:
         description = sstrip('''
-            Remove task instances from the scheduler task pool.
+            Remove one or more task instances from a running workflow.
 
         ''')
         resolver = partial(mutator, command='remove_tasks')

diff --git a/cylc/flow/scheduler.py b/cylc/flow/scheduler.py
@@ -592,7 +592,7 @@ def load_tasks_for_run(self):
 
         for name in task_list:
             if self.config.start_point is None:
-                # TODO: no start cycle point at which to load cycling tasks?
+                # No start cycle point at which to load cycling tasks.
                 continue
             tdef = self.config.get_taskdef(name)
             spawn = []

diff --git a/cylc/flow/task_pool.py b/cylc/flow/task_pool.py
@@ -772,8 +772,6 @@ def set_do_reload(self, config):
             self.stop_point = config.final_point
         self.do_reload = True
 
-        # TODO SoD - need to restore runahead limit :-(
-        # self.custom_runahead_limit = self.config.get_custom_runahead_limit()
         self.custom_runahead_limit = self.config.get_custom_runahead_limit()
         self.max_num_active_cycle_points = (
             self.config.get_max_num_active_cycle_points())
@@ -1153,7 +1151,6 @@ def spawn_tasks(self, items, failed, non_failed):
             for taskdef in taskdefs:
                 task_items[(taskdef.name, point_str)] = taskdef
                 select_args.append((taskdef.name, point_str))
-        # TODO - this only works for the initial spawning!
         submit_nums = self.suite_db_mgr.pri_dao.select_submit_nums(
             select_args)
         for key, taskdef in sorted(task_items.items()):