Skip to content

Commit

Permalink
Remove dead code.
Browse files Browse the repository at this point in the history
  • Loading branch information
hjoliver committed Dec 23, 2024
1 parent e06321c commit b6778b6
Showing 1 changed file with 2 additions and 8 deletions.
10 changes: 2 additions & 8 deletions cylc/flow/task_pool.py
Original file line number Diff line number Diff line change
Expand Up @@ -1973,9 +1973,6 @@ def set_prereqs_and_outputs(
else:
flow_nums = self._get_flow_nums(flow, flow_descr)

if flow_nums is None:
return

# Get matching pool tasks and inactive task definitions.
itasks, inactive_tasks, unmatched = self.filter_task_proxies(
items,
Expand Down Expand Up @@ -2115,6 +2112,7 @@ def _set_prereqs_tdef(
taskdef.name, point, flow_nums, flow_wait=flow_wait, force=True
)
if itask is None:
# TODO is this possible?
return None

Check warning on line 2116 in cylc/flow/task_pool.py

View check run for this annotation

Codecov / codecov/patch

cylc/flow/task_pool.py#L2116

Added line #L2116 was not covered by tests

self.db_add_new_flow_rows(itask)
Expand Down Expand Up @@ -2547,11 +2545,7 @@ def match_inactive_tasks(

point = get_point(point_str)
for name in [m.name for m in members]:
try:
taskdef = self.config.taskdefs[name]
except KeyError:
# family name
continue
taskdef = self.config.taskdefs[name]
if taskdef.is_valid_point(point):
matched_tasks.add((taskdef, point))
else:
Expand Down

0 comments on commit b6778b6

Please sign in to comment.