From 786483acfaa232726b7aafacd7985b050c0326ac Mon Sep 17 00:00:00 2001 From: Dave McKay Date: Fri, 10 Jan 2025 11:05:23 +0000 Subject: [PATCH] return type metadata --- csd3-side/scripts/lsst-backup.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/csd3-side/scripts/lsst-backup.py b/csd3-side/scripts/lsst-backup.py index d866192..cf7adaa 100644 --- a/csd3-side/scripts/lsst-backup.py +++ b/csd3-side/scripts/lsst-backup.py @@ -1209,7 +1209,7 @@ def process_files(s3, bucket_name, api, current_objects, exclude, local_dir, des # to_collate = dd.from_pandas(to_collate, npartitions=len(client.scheduler_info()['workers'])*10) print('Created Dask dataframe for to_collate.', flush=True) to_collate = to_collate.drop(columns=['upload']) - to_collate['upload'] = to_collate['object_names'].apply(compare_zip_contents_bool, current_objects, destination_dir) + to_collate['upload'] = to_collate['object_names'].apply(compare_zip_contents_bool, current_objects, destination_dir, meta=('return_bool', 'bool')) # to_collate = to_collate.rename(columns={'_upload':'upload'}) print('Comparison setup.', flush=True) to_collate = to_collate.compute()