(*args, **kwargs)
| 639 | using_custom_scheduler = False |
| 640 | |
| 641 | def custom_scheduler(*args, **kwargs): |
| 642 | nonlocal using_custom_scheduler |
| 643 | try: |
| 644 | using_custom_scheduler = True |
| 645 | return get_sync(*args, **kwargs) |
| 646 | finally: |
| 647 | using_custom_scheduler = False |
| 648 | |
| 649 | def check_custom_scheduler(part: pd.DataFrame) -> pd.DataFrame: |
| 650 | assert using_custom_scheduler, "not using custom scheduler" |
nothing calls this directly
no test coverage detected