From e6b6eaf3dd6a06001d1507071a6b36b6e0a9fe7e Mon Sep 17 00:00:00 2001 From: Max Jones <14077947+maxrjones@users.noreply.github.com> Date: Mon, 29 Jan 2024 15:28:14 -0500 Subject: [PATCH] Update LazyReferenceMapper.create() syntax in docs --- docs/source/advanced.rst | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/docs/source/advanced.rst b/docs/source/advanced.rst index 7ab08d51..914920a8 100644 --- a/docs/source/advanced.rst +++ b/docs/source/advanced.rst @@ -167,16 +167,18 @@ one go and may be faster, if you have a Dask cluster available. fs = fsspec.filesystem("file") os.makedirs("combined.parq") - out = LazyReferenceMapper.create(1000, "combined.parq", fs) + out = LazyReferenceMapper.create(record_size=1000, root="combined.parq", fs=fs) # Create references from input files single_ref_sets = [hdf.SingleHdf5ToZarr(_).translate() for _ in files] out_dict = MultiZarrToZarr( single_ref_sets, - remote_protocol="memory", + remote_protocol="s3", concat_dims=["time"], - out=out).translate() + remote_options={"anon": True}, + out=out + ).translate() out.flush()