d69aa1862f77db07d8aee64303fa6576701850af,scanpy/preprocessing/_simple.py,,regress_out,#Any#Any#Any#Any#,572

Before Change

    if n_jobs > 1 and n_chunks > 1:
        import multiprocessing

        pool = multiprocessing.Pool(n_jobs)
        res = pool.map_async(_regress_out_chunk, tasks).get(9999999)
        pool.close()

    else:
        res = list(map(_regress_out_chunk, tasks))

After Change

    from joblib import Parallel, delayed

    // TODO: figure out how to test that this doesn"t oversubscribe resources
    res = Parallel(n_jobs=n_jobs)(delayed(_regress_out_chunk)(task) for task in tasks)

    // res is a list of vectors (each corresponding to a regressed gene column).
    // The transpose is needed to get the matrix in the shape needed
    adata.X = np.vstack(res).T.astype(adata.X.dtype)

Instances