Skip to content

Commit

Permalink
Patch used before created reference
Browse files Browse the repository at this point in the history
  • Loading branch information
BryanFauble committed Dec 16, 2024
1 parent 50cebee commit 734241f
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion synapseclient/core/download/download_functions.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
4 changes: 2 additions & 2 deletions synapseclient/models/mixins/storable_container.py
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down Expand Up @@ -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,
Expand Down

0 comments on commit 734241f

Please sign in to comment.