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,