Function get_apply_async

dask/local.py:628–631

(apply_async, num_workers, *args, **kwargs)

def get_apply_async(apply_async, num_workers, *args, **kwargs):
    return get_async(
        partial(submit_apply_async, apply_async), num_workers, *args, **kwargs
    )


def sortkey(item):