From 734241fe59098851c8d0454e82676fd7bc385f59 Mon Sep 17 00:00:00 2001 From: BryanFauble <17128019+BryanFauble@users.noreply.github.com> Date: Mon, 16 Dec 2024 15:18:51 -0700 Subject: [PATCH] Patch used before created reference --- synapseclient/core/download/download_functions.py | 2 +- synapseclient/models/mixins/storable_container.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/synapseclient/core/download/download_functions.py b/synapseclient/core/download/download_functions.py index 558f7a18e..74649ece3 100644 --- a/synapseclient/core/download/download_functions.py +++ b/synapseclient/core/download/download_functions.py @@ -553,7 +553,7 @@ def download_fn( exc_info = sys.exc_info() ex.progress = 0 if not hasattr(ex, "progress") else ex.progress syn.logger.debug( - f"\n[{synapse_id}:{os.path.basename(downloaded_path)}]: Retrying " + f"\n[{synapse_id}]: Retrying " f"download on error: [{exc_info[0]}] after progressing {ex.progress} bytes", exc_info=True, ) # this will include stack trace diff --git a/synapseclient/models/mixins/storable_container.py b/synapseclient/models/mixins/storable_container.py index 5f55c837b..002086aeb 100644 --- a/synapseclient/models/mixins/storable_container.py +++ b/synapseclient/models/mixins/storable_container.py @@ -55,7 +55,7 @@ class StorableContainer(StorableContainerSynchronousProtocol): async def get_async(self, *, synapse_client: Optional[Synapse] = None) -> None: """Used to satisfy the usage in this mixin from the parent class.""" - async def worker( + async def _worker( self, queue: asyncio.Queue, failure_strategy: FailureStrategy, @@ -323,7 +323,7 @@ async def _sync_from_synapse_async( if create_workers: for _ in range(max(syn.max_threads * 2, 1)): task = asyncio.create_task( - self.worker( + self._worker( queue=queue, failure_strategy=failure_strategy, synapse_client=syn,