MCPcopy Create free account
hub / github.com/dask/dask / custom_scheduler

Function custom_scheduler

dask/dataframe/tests/test_utils_dataframe.py:636–642  ·  view source on GitHub ↗
(*args, **kwargs)

Source from the content-addressed store, hash-verified

634 using_custom_scheduler = False
635
636 def custom_scheduler(*args, **kwargs):
637 nonlocal using_custom_scheduler
638 try:
639 using_custom_scheduler = True
640 return get_sync(*args, **kwargs)
641 finally:
642 using_custom_scheduler = False
643
644 def check_custom_scheduler(part: pd.DataFrame) -> pd.DataFrame:
645 assert using_custom_scheduler, "not using custom scheduler"

Callers

nothing calls this directly

Calls 1

get_syncFunction · 0.90

Tested by

no test coverage detected