(
table: Table | tuple[Table, ...], expected: Table | tuple[Table, ...], **kwargs
)
| 590 | ) |
| 591 | |
| 592 | def inner( |
| 593 | table: Table | tuple[Table, ...], expected: Table | tuple[Table, ...], **kwargs |
| 594 | ): |
| 595 | if isinstance(table, Table): |
| 596 | table = (table,) |
| 597 | if isinstance(expected, Table): |
| 598 | expected = (expected,) |
| 599 | for t, ex in zip(table, expected, strict=True): |
| 600 | assert_schemas_the_same(t, ex) |
| 601 | |
| 602 | apply_defaults_for_run_kwargs(kwargs) |
| 603 | print("We will do GraphRunner with the following kwargs: ", kwargs) |
| 604 | |
| 605 | captured = GraphRunner( |
| 606 | table[0]._source.graph, _stacklevel=2, **kwargs |
| 607 | ).run_tables(*table, *expected) |
| 608 | n = len(expected) |
| 609 | captured_tables, captured_expected = captured[:n], captured[n:] |
| 610 | for captured_t, captured_ex in zip(captured_tables, captured_expected): |
| 611 | verifier( |
| 612 | captured_t, |
| 613 | captured_ex, |
| 614 | terminate_on_error=kwargs.get("terminate_on_error", True), |
| 615 | ) |
| 616 | |
| 617 | return inner |
| 618 |
nothing calls this directly
no test coverage detected