fix: catch CancelledError in checker pipeline to prevent sweep crash

2026-03-15 16:48:28 -04:00 · 2026-03-15 16:48:28 -04:00 · ee3b061162
commit ee3b061162
parent 06078db34a
1 changed files with 5 additions and 0 deletions
--- a/src/proxy_pool/worker/tasks_validate.py
+++ b/src/proxy_pool/worker/tasks_validate.py
@ -35,6 +35,11 @@ async def _run_single_check(checker, proxy, context) -> CheckResult:
            passed=False,
            detail=f"{checker.name} timed out after {checker.timeout}s",
        )
+    except asyncio.CancelledError:
+        return CheckResult(
+            passed=False,
+            detail=f"{checker.name} was cancelled",
+        )
    except Exception as err:
        return CheckResult(
            passed=False,