From 0c367df5064f2da8db842e867b89efae7ad8cb01 Mon Sep 17 00:00:00 2001 From: Martin Durant Date: Fri, 5 Apr 2024 10:02:00 -0400 Subject: [PATCH] remember to commit --- src/dask_awkward/lib/io/io.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/dask_awkward/lib/io/io.py b/src/dask_awkward/lib/io/io.py index 46849daf..0298f06a 100644 --- a/src/dask_awkward/lib/io/io.py +++ b/src/dask_awkward/lib/io/io.py @@ -36,7 +36,7 @@ typetracer_array, ) from dask_awkward.lib.io.columnar import ColumnProjectionMixin -from dask_awkward.lib.utils import render_buffer_key +from dask_awkward.lib.utils import form_with_unique_keys, render_buffer_key from dask_awkward.utils import first, second if TYPE_CHECKING: @@ -626,11 +626,12 @@ def from_map( # so here we start with a blank report io_func = func array_meta, report = typetracer_with_report( - io_func.form, + form_with_unique_keys(io_func.form, "@"), highlevel=True, behavior=io_func.behavior, buffer_key=render_buffer_key, ) + report.commit(name) array_meta._report = { report } # column tracking report, not failure report, below