GraphNode - class

Source on GitHub

pipeline.objects.graph.GraphNode(
    function: Function,
  inputs: List[Variable],
  outputs: List[Variable],
  *,
  local_id: str = None
)

Description

GraphNode objects store the references to input/output Variable objects to be used in conjunction with the Function object that's created by the pipeline_function decorator.

Parameters

• function (Function) - function to be executed at the node.
• inputs (List[Variable]) - input variables to be passed into the node.
• outputs (List[Function]) - variables to be returned form the node.
• local_id (str, optional) - graph ID for the node.

Functions

to_create_schema(self) -> PipelineGraphNode

Description

Returns the schema defining the graph node to send remotely.