From ee3b061162749b6ded6fd014b421be43d787578b Mon Sep 17 00:00:00 2001 From: agatha Date: Sun, 15 Mar 2026 16:48:28 -0400 Subject: [PATCH] fix: catch CancelledError in checker pipeline to prevent sweep crash --- src/proxy_pool/worker/tasks_validate.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/proxy_pool/worker/tasks_validate.py b/src/proxy_pool/worker/tasks_validate.py index a3dc13e..3c3f0c1 100644 --- 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,