Skip to content

Commit 62d801c

Browse files
committed
additional task_fields->get_fields changes
1 parent 325a8db commit 62d801c

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

pydra/engine/node.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -114,13 +114,13 @@ def state_values(self) -> dict[str, ty.Any]:
114114

115115
@property
116116
def lzout(self) -> OutputType:
117-
from pydra.utils.general import task_fields
117+
from pydra.utils.general import get_fields
118118

119119
"""The output task of the node populated with lazy fields"""
120120
if self._lzout is not None:
121121
return self._lzout
122122
lazy_fields = {}
123-
for field in task_fields(self.inputs.Outputs):
123+
for field in get_fields(self.inputs.Outputs):
124124
lazy_fields[field.name] = lazy.LazyOutField(
125125
node=self,
126126
field=field.name,

pydra/engine/tests/utils.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
import subprocess as sp
1010
import pytest
1111
from fileformats.generic import File
12-
from pydra.utils.general import task_fields
12+
from pydra.utils.general import get_fields
1313
from pydra.engine.submitter import Submitter
1414
from pydra.compose import workflow, python, shell
1515

@@ -44,7 +44,7 @@ def num_python_cache_roots(cache_path: Path) -> int:
4444

4545

4646
def get_output_names(task):
47-
return sorted(f.name for f in task_fields(task.Outputs))
47+
return sorted(f.name for f in get_fields(task.Outputs))
4848

4949

5050
def run_no_submitter(

0 commit comments

Comments
 (0)