Skip to content

Commit

Permalink
Reuse existing family hierarchy info.
Browse files Browse the repository at this point in the history
  • Loading branch information
hjoliver committed Mar 11, 2024
1 parent c0e132c commit 96fa7de
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 9 deletions.
4 changes: 0 additions & 4 deletions cylc/flow/config.py
Original file line number Diff line number Diff line change
Expand Up @@ -575,10 +575,6 @@ def __init__(

self.mem_log("config.py: end init config")

self.namespaces: Dict[str, List[str]] = {}
for name in self.taskdefs:
self.namespaces[name] = self.taskdefs[name].namespace_hierarchy

@staticmethod
def _warn_if_queues_have_implicit_tasks(
config, taskdefs, max_warning_lines
Expand Down
6 changes: 2 additions & 4 deletions cylc/flow/task_pool.py
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,6 @@
filter_ids,
filter_ids_2
)
from cylc.flow.network.resolvers import TaskMsg
from cylc.flow.workflow_status import StopMode
from cylc.flow.task_action_timer import TaskActionTimer, TimerFlags
from cylc.flow.task_events_mgr import (
Expand Down Expand Up @@ -1259,9 +1258,8 @@ def release_held_tasks(self, items: Iterable[str]) -> int:
# so only 'waiting' is valid as a state selector.
future_matched: 'Set[Tuple[str, PointBase]]' = set()
future_matched, unmatched_future = filter_ids_2(
self.tasks_to_hold,
items,
self.config.namespaces
self.tasks_to_hold, items,
self.config.runtime['linearized ancestors']
)
# Release matching tasks.
for name, cycle in future_matched:
Expand Down
1 change: 0 additions & 1 deletion cylc/flow/task_proxy.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@
from copy import copy
from typing import (
Any,
Callable,
Counter as TypingCounter,
Dict,
List,
Expand Down

0 comments on commit 96fa7de

Please sign in to comment.