Function get_sync

dask/local.py:587–599

A naive synchronous version of get_async Can be useful for debugging.

(dsk: Mapping, keys: Sequence[Key] | Key, **kwargs)

def get_sync(dsk: Mapping, keys: Sequence[Key] | Key, **kwargs):
    """A naive synchronous version of get_async

    Can be useful for debugging.
    """
    kwargs.pop("num_workers", None)  # if num_workers present, remove it
    return get_async(
        synchronous_executor.submit,
        synchronous_executor._max_workers,
        dsk,
        keys,
        **kwargs,
    )


""" Adaptor for ``multiprocessing.Pool`` instances