Retry on all errors (timeouts, crashes) instead of giving up

2026-07-10 20:47:57 +03:00
parent 146609bbae
commit f0a6b79a82
1 changed files with 5 additions and 1 deletions
@@ -775,7 +775,11 @@ def _process_one(tid: int, acc: dict,
                    continue
                break
            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
            finally:
                if TEST_MODE: