Cover executor-shutdown runtime errors as non-retryable

Co-authored-by: Shri Sukhani <shrisukhani@users.noreply.github.com>

Author: cursoragent

hyperbrowser/client/polling.py

@@ -152,13 +152,25 @@ def _is_async_loop_contract_runtime_error(exc: Exception) -> bool:
         return True
     if "event loop other than the current one" in normalized_message:
         return True
+    if "attached to a different loop" in normalized_message:
+        return True
     if "different event loop" in normalized_message:
         return True
     return "different loop" in normalized_message and any(
         marker in normalized_message for marker in ("future", "task")
     )
 
 
+def _is_executor_shutdown_runtime_error(exc: Exception) -> bool:
+    if not isinstance(exc, RuntimeError):
+        return False
+    normalized_message = str(exc).lower()
+    return (
+        "cannot schedule new futures after" in normalized_message
+        and "shutdown" in normalized_message
+    )
+
+
 def _is_retryable_exception(exc: Exception) -> bool:
     if isinstance(exc, (StopIteration, StopAsyncIteration)):
         return False
@@ -170,6 +182,8 @@ def _is_retryable_exception(exc: Exception) -> bool:
         return False
     if _is_async_loop_contract_runtime_error(exc):
         return False
+    if _is_executor_shutdown_runtime_error(exc):
+        return False
     if isinstance(exc, ConcurrentCancelledError):
         return False
     if isinstance(exc, _NonRetryablePollingError):

tests/test_polling.py

@@ -1365,6 +1365,26 @@ def operation() -> str:
     assert attempts["count"] == 1
 
 
+def test_retry_operation_does_not_retry_executor_shutdown_runtime_errors():
+    attempts = {"count": 0}
+
+    def operation() -> str:
+        attempts["count"] += 1
+        raise RuntimeError("cannot schedule new futures after interpreter shutdown")
+
+    with pytest.raises(
+        RuntimeError, match="cannot schedule new futures after interpreter shutdown"
+    ):
+        retry_operation(
+            operation_name="sync retry executor-shutdown runtime error",
+            operation=operation,
+            max_attempts=5,
+            retry_delay_seconds=0.0001,
+        )
+
+    assert attempts["count"] == 1
+
+
 def test_poll_until_terminal_status_async_does_not_retry_runtime_errors_for_closed_loop():
     async def run() -> None:
         attempts = {"count": 0}
@@ -1388,6 +1408,31 @@ async def get_status() -> str:
     asyncio.run(run())
 
 
+def test_poll_until_terminal_status_async_does_not_retry_executor_shutdown_runtime_errors():
+    async def run() -> None:
+        attempts = {"count": 0}
+
+        async def get_status() -> str:
+            attempts["count"] += 1
+            raise RuntimeError("cannot schedule new futures after shutdown")
+
+        with pytest.raises(
+            RuntimeError, match="cannot schedule new futures after shutdown"
+        ):
+            await poll_until_terminal_status_async(
+                operation_name="async poll executor-shutdown runtime error",
+                get_status=get_status,
+                is_terminal_status=lambda value: value == "completed",
+                poll_interval_seconds=0.0001,
+                max_wait_seconds=1.0,
+                max_status_failures=5,
+            )
+
+        assert attempts["count"] == 1
+
+    asyncio.run(run())
+
+
 def test_poll_until_terminal_status_async_does_not_retry_runtime_errors_for_non_thread_safe_loop_operation():
     async def run() -> None:
         attempts = {"count": 0}