

def get_sync(dsk, keys, **kwargs):
    from .compatibility import Queue
    kwargs.pop('num_workers', None)
    queue = Queue()
    return get_async(apply_sync, 1, dsk, keys, queue=queue, raise_on_exception=True, **kwargs)

dataset/ETHPy150Open dask/dask/dask/async.py get_sync/original