Skip to content

Commit a52b748

Browse files
committed
renamed NodeExecution.task to NodeExecution.get_tasks
1 parent 2664509 commit a52b748

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

pydra/engine/lazy.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ def _get_value(
160160
if state_index is None:
161161
state_index = StateIndex()
162162

163-
task = graph.node(self._node.name).task(state_index)
163+
task = graph.node(self._node.name).get_tasks(state_index)
164164
_, split_depth = TypeParser.strip_splits(self._type)
165165

166166
def get_nested(task: "Task[DefType]", depth: int):

pydra/engine/submitter.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -568,7 +568,7 @@ def tasks(self) -> ty.Iterable["Task[DefType]"]:
568568
self._tasks = {t.state_index: t for t in self._generate_tasks()}
569569
return self._tasks.values()
570570

571-
def task(
571+
def get_tasks(
572572
self, index: StateIndex = StateIndex()
573573
) -> "Task | StateArray[Task[DefType]]":
574574
"""Get a task object for a given state index."""
@@ -740,7 +740,7 @@ def get_runnable_tasks(self, graph: DiGraph) -> list["Task[DefType]"]:
740740
pred: NodeExecution
741741
is_runnable = True
742742
for pred in graph.predecessors[self.node.name]:
743-
pred_jobs = pred.task(index)
743+
pred_jobs = pred.get_tasks(index)
744744
if isinstance(pred_jobs, StateArray):
745745
pred_inds = [j.state_index for j in pred_jobs]
746746
else:

0 commit comments

Comments
 (0)