From 67ab7d7f8eeb152aeb45ce8182d2d88f894b80eb Mon Sep 17 00:00:00 2001 From: Lindsey Gray Date: Fri, 1 Mar 2024 12:41:42 -0600 Subject: [PATCH 1/3] more obvious names for report products --- src/dask_awkward/lib/io/io.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/dask_awkward/lib/io/io.py b/src/dask_awkward/lib/io/io.py index b3108081..7c50b734 100644 --- a/src/dask_awkward/lib/io/io.py +++ b/src/dask_awkward/lib/io/io.py @@ -640,8 +640,10 @@ def from_map( if io_func_implements_report(io_func): if cast(ImplementsReport, io_func).return_report: - res = result.map_partitions(first, meta=array_meta, output_divisions=1) - rep = result.map_partitions(second, meta=empty_typetracer()) + res = result.map_partitions( + first, meta=array_meta, label=label, output_divisions=1 + ) + rep = result.map_partitions(second, meta=empty_typetracer(), label="report") return res, rep return result From 23615f5707ebc32e4f9b6bb47cf8d9e36fb08bb6 Mon Sep 17 00:00:00 2001 From: Lindsey Gray Date: Fri, 1 Mar 2024 12:57:40 -0600 Subject: [PATCH 2/3] better naming for report --- src/dask_awkward/lib/io/io.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/dask_awkward/lib/io/io.py b/src/dask_awkward/lib/io/io.py index 7c50b734..a8f7cdb1 100644 --- a/src/dask_awkward/lib/io/io.py +++ b/src/dask_awkward/lib/io/io.py @@ -643,7 +643,7 @@ def from_map( res = result.map_partitions( first, meta=array_meta, label=label, output_divisions=1 ) - rep = result.map_partitions(second, meta=empty_typetracer(), label="report") + rep = result.map_partitions(second, meta=empty_typetracer(), label=f"{label}-report") return res, rep return result From 9b972399e09f628867442b5458bc9be65d112add Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Fri, 1 Mar 2024 18:58:42 +0000 Subject: [PATCH 3/3] [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --- src/dask_awkward/lib/io/io.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/dask_awkward/lib/io/io.py b/src/dask_awkward/lib/io/io.py index a8f7cdb1..75adbc74 100644 --- a/src/dask_awkward/lib/io/io.py +++ b/src/dask_awkward/lib/io/io.py @@ -643,7 +643,9 @@ def from_map( res = result.map_partitions( first, meta=array_meta, label=label, output_divisions=1 ) - rep = result.map_partitions(second, meta=empty_typetracer(), label=f"{label}-report") + rep = result.map_partitions( + second, meta=empty_typetracer(), label=f"{label}-report" + ) return res, rep return result