()
| 705 | |
| 706 | |
| 707 | def datasource1_exception(): |
| 708 | schema = datasource1_schema() |
| 709 | |
| 710 | def batch_gen(ctx): |
| 711 | for n in range(3, 0, -1): |
| 712 | # ctx = |
| 713 | yield _record_batch_for_range(schema, n - 1) |
| 714 | raise RuntimeError("datasource1_exception") |
| 715 | return make_udt_func(schema, batch_gen) |
| 716 | |
| 717 | |
| 718 | def datasource1_schema(): |
nothing calls this directly
no test coverage detected