Skip to content

Commit bac53ff

Browse files
committed
refactor manifest functions for readability
1 parent 33b461a commit bac53ff

4 files changed

Lines changed: 877 additions & 583 deletions

File tree

synapseclient/models/mixins/storable_container.py

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -48,8 +48,8 @@
4848
StorableContainerSynchronousProtocol,
4949
)
5050
from synapseclient.models.services.manifest import (
51-
SyncUploader,
5251
read_manifest_for_upload,
52+
upload_sync_files,
5353
)
5454
from synapseclient.models.services.storable_entity_components import (
5555
MANIFEST_UPLOAD_MAX_RETRIES,
@@ -606,15 +606,16 @@ async def main():
606606
)
607607
with upload_shared_progress_bar(progress_bar):
608608
try:
609-
uploader = SyncUploader(syn)
610609
if send_messages:
611610
notify_decorator = notify_me_async(
612611
syn, f"Upload from {manifest_path}", retries=retries
613612
)
614-
upload_fn = notify_decorator(uploader.upload)
615-
uploaded_files = await upload_fn(items)
613+
wrapped = notify_decorator(
614+
lambda items: upload_sync_files(items, syn=syn)
615+
)
616+
uploaded_files = await wrapped(items)
616617
else:
617-
uploaded_files = await uploader.upload(items)
618+
uploaded_files = await upload_sync_files(items, syn=syn)
618619
progress_bar.update(total_size - progress_bar.n)
619620
finally:
620621
progress_bar.close()

0 commit comments

Comments
 (0)