Expand wait-helper bytes-like status path fallback coverage

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

Author: cursoragent

tests/test_polling.py

@@ -3877,6 +3877,38 @@ def fetch_result() -> dict:
     assert fetch_attempts["count"] == 0
 
 
+def test_wait_for_job_result_does_not_retry_bytes_like_status_errors():
+    status_attempts = {"count": 0}
+    fetch_attempts = {"count": 0}
+
+    def get_status() -> str:
+        status_attempts["count"] += 1
+        raise HyperbrowserError(
+            "client failure",
+            status_code=array("B", [52, 48, 48]),  # type: ignore[arg-type]
+        )
+
+    def fetch_result() -> dict:
+        fetch_attempts["count"] += 1
+        return {"ok": True}
+
+    with pytest.raises(HyperbrowserError, match="client failure"):
+        wait_for_job_result(
+            operation_name="sync wait helper status bytes-like client error",
+            get_status=get_status,
+            is_terminal_status=lambda value: value == "completed",
+            fetch_result=fetch_result,
+            poll_interval_seconds=0.0001,
+            max_wait_seconds=1.0,
+            max_status_failures=5,
+            fetch_max_attempts=5,
+            fetch_retry_delay_seconds=0.0001,
+        )
+
+    assert status_attempts["count"] == 1
+    assert fetch_attempts["count"] == 0
+
+
 def test_wait_for_job_result_retries_overlong_numeric_bytes_status_errors():
     status_attempts = {"count": 0}
     fetch_attempts = {"count": 0}
@@ -3911,6 +3943,40 @@ def fetch_result() -> dict:
     assert fetch_attempts["count"] == 1
 
 
+def test_wait_for_job_result_retries_overlong_bytes_like_status_errors():
+    status_attempts = {"count": 0}
+    fetch_attempts = {"count": 0}
+
+    def get_status() -> str:
+        status_attempts["count"] += 1
+        if status_attempts["count"] < 3:
+            raise HyperbrowserError(
+                "oversized status metadata",
+                status_code=array("B", [52, 48, 48, 48, 48, 48, 48]),  # type: ignore[arg-type]
+            )
+        return "completed"
+
+    def fetch_result() -> dict:
+        fetch_attempts["count"] += 1
+        return {"ok": True}
+
+    result = wait_for_job_result(
+        operation_name="sync wait helper status oversized bytes-like retries",
+        get_status=get_status,
+        is_terminal_status=lambda value: value == "completed",
+        fetch_result=fetch_result,
+        poll_interval_seconds=0.0001,
+        max_wait_seconds=1.0,
+        max_status_failures=5,
+        fetch_max_attempts=5,
+        fetch_retry_delay_seconds=0.0001,
+    )
+
+    assert result == {"ok": True}
+    assert status_attempts["count"] == 3
+    assert fetch_attempts["count"] == 1
+
+
 def test_wait_for_job_result_does_not_retry_broken_executor_status_errors():
     status_attempts = {"count": 0}
     fetch_attempts = {"count": 0}
@@ -4752,6 +4818,41 @@ async def fetch_result() -> dict:
     asyncio.run(run())
 
 
+def test_wait_for_job_result_async_does_not_retry_bytes_like_status_errors():
+    async def run() -> None:
+        status_attempts = {"count": 0}
+        fetch_attempts = {"count": 0}
+
+        async def get_status() -> str:
+            status_attempts["count"] += 1
+            raise HyperbrowserError(
+                "client failure",
+                status_code=array("B", [52, 48, 52]),  # type: ignore[arg-type]
+            )
+
+        async def fetch_result() -> dict:
+            fetch_attempts["count"] += 1
+            return {"ok": True}
+
+        with pytest.raises(HyperbrowserError, match="client failure"):
+            await wait_for_job_result_async(
+                operation_name="async wait helper status bytes-like client error",
+                get_status=get_status,
+                is_terminal_status=lambda value: value == "completed",
+                fetch_result=fetch_result,
+                poll_interval_seconds=0.0001,
+                max_wait_seconds=1.0,
+                max_status_failures=5,
+                fetch_max_attempts=5,
+                fetch_retry_delay_seconds=0.0001,
+            )
+
+        assert status_attempts["count"] == 1
+        assert fetch_attempts["count"] == 0
+
+    asyncio.run(run())
+
+
 def test_wait_for_job_result_async_retries_overlong_numeric_bytes_status_errors():
     async def run() -> None:
         status_attempts = {"count": 0}
@@ -4789,6 +4890,43 @@ async def fetch_result() -> dict:
     asyncio.run(run())
 
 
+def test_wait_for_job_result_async_retries_overlong_bytes_like_status_errors():
+    async def run() -> None:
+        status_attempts = {"count": 0}
+        fetch_attempts = {"count": 0}
+
+        async def get_status() -> str:
+            status_attempts["count"] += 1
+            if status_attempts["count"] < 3:
+                raise HyperbrowserError(
+                    "oversized status metadata",
+                    status_code=array("B", [52, 48, 48, 48, 48, 48, 48]),  # type: ignore[arg-type]
+                )
+            return "completed"
+
+        async def fetch_result() -> dict:
+            fetch_attempts["count"] += 1
+            return {"ok": True}
+
+        result = await wait_for_job_result_async(
+            operation_name="async wait helper status oversized bytes-like retries",
+            get_status=get_status,
+            is_terminal_status=lambda value: value == "completed",
+            fetch_result=fetch_result,
+            poll_interval_seconds=0.0001,
+            max_wait_seconds=1.0,
+            max_status_failures=5,
+            fetch_max_attempts=5,
+            fetch_retry_delay_seconds=0.0001,
+        )
+
+        assert result == {"ok": True}
+        assert status_attempts["count"] == 3
+        assert fetch_attempts["count"] == 1
+
+    asyncio.run(run())
+
+
 def test_wait_for_job_result_async_does_not_retry_broken_executor_status_errors():
     async def run() -> None:
         status_attempts = {"count": 0}