MCPcopy Create free account
hub / github.com/pathwaycom/pathway / DebugOperator

Class DebugOperator

python/pathway/internals/operator.py:233–249  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

231
232
233class DebugOperator(Operator):
234 name: str
235 table: tables.Table
236
237 def __init__(self, name: str, id: int):
238 super().__init__(id)
239 self.name = name
240
241 def __call__(self, table: tables.Table) -> None:
242 self._prepare_inputs(as_arg_tuple(table))
243 self.table = table
244
245 def label(self):
246 return f"debug: {self.name}"
247
248 def hard_table_dependencies(self) -> StableSet[tables.Table]:
249 return self.input_tables
250
251
252TTable = TypeVar("TTable", bound="tables.Table[Any]")

Callers 1

debugMethod · 0.90

Calls

no outgoing calls

Tested by

no test coverage detected