(results)
| 521 | repack_dsk[out] = Task(out, tuple, List(*[_unpack(i) for i in args])) |
| 522 | |
| 523 | def repack(results): |
| 524 | dsk = repack_dsk.copy() |
| 525 | dsk[collections_token] = DataNode(collections_token, results) |
| 526 | return simple_get(dsk, out) |
| 527 | |
| 528 | # The original `collections` is kept alive by the closure |
| 529 | # This causes the collection to be only freed by the garbage collector |