Function repack

dask/base.py:527–530

(results)

    repack_dsk[out] = Task(out, tuple, List(*[_unpack(i) for i in args]))

    def repack(results):
        dsk = repack_dsk.copy()
        dsk[collections_token] = DataNode(collections_token, results)
        return simple_get(dsk, out)

    # The original `collections` is kept alive by the closure
    # This causes the collection to be only freed by the garbage collector