Skip to content

Commit ed4e923

Browse files
committed
chore: renamed *.Outputs._from_task to _from_job to match new nomenclature
1 parent 4beb6a0 commit ed4e923

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

pydra/compose/base/task.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ def inputs(self):
5151
return self._node.inputs
5252

5353
@classmethod
54-
def _from_task(cls, job: "Job[TaskType]") -> Self:
54+
def _from_job(cls, job: "Job[TaskType]") -> Self:
5555
"""Collect the outputs of a job. This is just an abstract base method that
5656
should be used by derived classes to set default values for the outputs.
5757

pydra/compose/python.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -203,7 +203,7 @@ def make(wrapped: ty.Callable | type) -> Task:
203203
class PythonOutputs(base.Outputs):
204204

205205
@classmethod
206-
def _from_task(cls, job: "Job[PythonTask]") -> ty.Self:
206+
def _from_job(cls, job: "Job[PythonTask]") -> ty.Self:
207207
"""Collect the outputs of a job from a combination of the provided inputs,
208208
the objects in the output directory, and the stdout and stderr of the process.
209209

pydra/compose/shell/task.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ class ShellOutputs(base.Outputs):
5656
stderr: str = field.out(name="stderr", type=str, help=STDERR_HELP)
5757

5858
@classmethod
59-
def _from_task(cls, job: "Job[Task]") -> ty.Self:
59+
def _from_job(cls, job: "Job[Task]") -> ty.Self:
6060
"""Collect the outputs of a shell process from a combination of the provided inputs,
6161
the objects in the output directory, and the stdout and stderr of the process.
6262

pydra/compose/workflow.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -291,7 +291,7 @@ def cast(field: ty.Any, new_type: type[U]) -> U:
291291
class WorkflowOutputs(base.Outputs):
292292

293293
@classmethod
294-
def _from_task(cls, job: "Job[WorkflowTask]") -> ty.Self:
294+
def _from_job(cls, job: "Job[WorkflowTask]") -> ty.Self:
295295
"""Collect the outputs of a workflow job from the outputs of the nodes in the
296296
297297
Parameters

0 commit comments

Comments
 (0)