MCPcopy
hub / github.com/pathwaycom/pathway / logic

Function logic

python/pathway/tests/test_persistence.py:363–365  ·  view source on GitHub ↗
(t_1: pw.Table, t_2: pw.Table)

Source from the content-addressed store, hash-verified

361 a: int = pw.column_definition(primary_key=True)
362
363 def logic(t_1: pw.Table, t_2: pw.Table) -> pw.Table:
364 t_2.promise_universe_is_subset_of(t_1)
365 return t_1.restrict(t_2)
366
367 run, _, input_path_2 = get_two_tables_runner(
368 tmp_path, mode, logic, InputSchema, terminate_on_error=False

Callers 1

run_computationFunction · 0.70

Calls 15

count_maxFunction · 0.85
promise_universe_is_subset_ofMethod · 0.80
restrictMethod · 0.80
with_columnsMethod · 0.80
with_universe_ofMethod · 0.80
intersectMethod · 0.80
differenceMethod · 0.80
sortMethod · 0.80
is_not_noneMethod · 0.80
update_rowsMethod · 0.80
update_cellsMethod · 0.80
countMethod · 0.80

Tested by

no test coverage detected