MCPcopy Index your code
hub / github.com/pathwaycom/pathway / InputHandle

Class InputHandle

python/pathway/internals/operator.py:58–71  ·  view source on GitHub ↗

Handle for the input of the Operator.

Source from the content-addressed store, hash-verified

56
57
58class InputHandle(InOut):
59 """Handle for the input of the Operator."""
60
61 value: OperatorInput
62
63 def __init__(self, operator: Operator, name: str, value: OperatorInput):
64 assert isinstance(value, OperatorInput)
65 super().__init__(operator, name)
66 self.value = value
67
68 @property
69 def dependencies(self) -> StableSet[Operator]:
70 input_tables = self.value._operator_dependencies()
71 return StableSet(table._source.operator for table in input_tables)
72
73
74class OutputHandle(InOut):

Callers 1

_prepare_inputsMethod · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected