Compare commits
1
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f0a6b79a82 |
@@ -775,7 +775,11 @@ def _process_one(tid: int, acc: dict,
|
|||||||
continue
|
continue
|
||||||
break
|
break
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
log.error("[T%d] Error: %s", tid, e)
|
log.error("[T%d] Error: %s (attempt %d/%d)", tid, e, attempt + 1, max_retries)
|
||||||
|
if attempt + 1 < max_retries:
|
||||||
|
log.info("[T%d] Retrying after error...", tid)
|
||||||
|
time.sleep(5)
|
||||||
|
continue
|
||||||
break
|
break
|
||||||
finally:
|
finally:
|
||||||
if TEST_MODE:
|
if TEST_MODE:
|
||||||
|
|||||||
Reference in New Issue
Block a user