Skip to content

Commit 263917d

Browse files
committed
fix: 忘记把纳秒转秒,导致睡了 3.0 * 1e10s
1 parent d4649fa commit 263917d

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

VERSION

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
3.0.1
1+
3.0.2

core/cluster.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -404,10 +404,11 @@ async def _download(self, session: aiohttp.ClientSession, file_queues: asyncio.Q
404404
file = failed_file.file
405405
t = max(0, min(failed_file.failed_times * 30, 600) * 1e9 - (time.monotonic_ns() - failed_file.last_failed_time))
406406
logger.tdebug("cluster.debug.retry_download", start_date=failed_file.first_time, file_path=file.path, file_hash=file.hash, file_size=units.format_bytes(file.size), time=units.format_count_time(t), count=failed_file.failed_times)
407-
await asyncio.sleep(t)
407+
await asyncio.sleep(t / 1e9)
408408
else:
409409
file = await file_queues.get()
410410
content = io.BytesIO()
411+
raise
411412
async with self.sync_sem:
412413
async with session.get(
413414
file.path

0 commit comments

Comments
 (0)