get

method of dascore.workflow.pipe.Pipe

source

get(
    self ,
    key: str ,
)-> ‘Task’

Return the task a node holds.

Examples

from dascore.workflow import Task
class PipeGetExample(Task):
    '''Add a number.'''
    value: int = 1
    def run(self, number):
        return number + self.value
pipe = PipeGetExample(value=1) | PipeGetExample(value=2)
assert pipe.get("pipe_get_example").value == 1
assert pipe.get("pipe_get_example_2").value == 2