()
| 894 | |
| 895 | |
| 896 | def test_get_scheduler(): |
| 897 | assert get_scheduler() is None |
| 898 | assert get_scheduler(scheduler=dask.local.get_sync) is dask.local.get_sync |
| 899 | assert get_scheduler(scheduler="threads") is dask.threaded.get |
| 900 | assert get_scheduler(scheduler="sync") is dask.local.get_sync |
| 901 | assert callable(get_scheduler(scheduler=dask.local.synchronous_executor)) |
| 902 | assert callable(get_scheduler(scheduler=MyExecutor())) |
| 903 | with dask.config.set(scheduler="threads"): |
| 904 | assert get_scheduler() is dask.threaded.get |
| 905 | assert get_scheduler() is None |
| 906 | |
| 907 | |
| 908 | def test_callable_scheduler(): |
nothing calls this directly
no test coverage detected