(results)
| 585 | repack_dsk[out] = Task(out, tuple, List(*[_unpack(i) for i in args])) |
| 586 | |
| 587 | def repack(results): |
| 588 | dsk = repack_dsk.copy() |
| 589 | dsk[collections_token] = DataNode(collections_token, results) |
| 590 | return simple_get(dsk, out) |
| 591 | |
| 592 | # The original `collections` is kept alive by the closure |
| 593 | # This causes the collection to be only freed by the garbage collector |