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

Method _set_source

python/pathway/internals/table.py:2479–2488  ·  view source on GitHub ↗
(self, source: OutputHandle)

Source from the content-addressed store, hash-verified

2477 )
2478
2479 def _set_source(self, source: OutputHandle):
2480 self._source = source
2481 if not hasattr(self._id_column, "lineage"):
2482 self._id_column.lineage = clmn.ColumnLineage(name="id", source=source)
2483 for name, column in self._columns.items():
2484 if not hasattr(column, "lineage"):
2485 column.lineage = clmn.ColumnLineage(name=name, source=source)
2486 universe = self._universe
2487 if not hasattr(universe, "lineage"):
2488 universe.lineage = clmn.Lineage(source=source)
2489
2490 @contextualized_operator
2491 def _unsafe_promise_universe(self, other: TableLike) -> Table:

Callers 2

_prepare_outputsMethod · 0.80
_copy_input_tableMethod · 0.80

Calls 1

itemsMethod · 0.80

Tested by

no test coverage detected