MCPcopy Create free account
hub / github.com/feast-dev/feast / add_input

Method add_input

sdk/python/feast/infra/compute_engines/dag/node.py:21–25  ·  view source on GitHub ↗
(self, node: "DAGNode")

Source from the content-addressed store, hash-verified

19 self.add_input(node)
20
21 def add_input(self, node: "DAGNode"):
22 if node in self.inputs:
23 raise ValueError(f"Input node {node.name} already added to {self.name}")
24 self.inputs.append(node)
25 node.outputs.append(self)
26
27 def get_input_values(self, context: ExecutionContext) -> List[DAGValue]:
28 input_values = []

Callers 15

__init__Method · 0.95
build_join_nodeMethod · 0.80
build_filter_nodeMethod · 0.80
build_dedup_nodeMethod · 0.80
__init__Method · 0.80
test_ray_join_nodeFunction · 0.80
test_ray_filter_nodeFunction · 0.80
test_ray_dedup_nodeFunction · 0.80

Calls

no outgoing calls