fix(http): guard private httpx attr, fix async comment, fix test mocks

- Wrap resp._request = None in try/except AttributeError for forward
  compat with future httpx versions
- Fix async_rest.py comment: BoundSyncStream → BoundAsyncStream
- Fix test_task_runner_coverage.py mocks: use mock_http_resp.data
  instead of dead mock_http_resp.resp (AuthorizationException now
  reads .data, not .resp.text)

Follow-up to #395

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: v1r3n

src/conductor/client/http/async_rest.py

@@ -13,9 +13,12 @@ def __init__(self, resp):
         self.reason = getattr(resp, 'reason_phrase', '') or self._get_reason_phrase(resp.status_code)
         self.data = resp.text                # eagerly read body
         self.headers = resp.headers
-        # Break httpx Response <-> BoundSyncStream reference cycle (issue #395)
+        # Break httpx Response <-> BoundAsyncStream reference cycle (issue #395)
         resp.stream = None
-        resp._request = None
+        try:
+            resp._request = None
+        except AttributeError:
+            pass
 
     def _get_reason_phrase(self, status_code):
         """Get HTTP reason phrase from status code."""

src/conductor/client/http/rest.py

@@ -15,7 +15,10 @@ def __init__(self, resp):
         self.headers = resp.headers
         # Break httpx Response <-> BoundSyncStream reference cycle (issue #395)
         resp.stream = None
-        resp._request = None
+        try:
+            resp._request = None
+        except AttributeError:
+            pass
 
     def _get_reason_phrase(self, status_code):
         """Get HTTP reason phrase from status code."""

tests/unit/automator/test_task_runner_coverage.py

@@ -316,15 +316,13 @@ def test_poll_task_auth_failure_with_invalid_token(self, mock_sleep):
         task_runner = TaskRunner(worker=worker)
 
         # Create mock response with INVALID_TOKEN error
-        mock_resp = Mock()
-        mock_resp.text = '{"error": "INVALID_TOKEN"}'
-
         mock_http_resp = Mock()
-        mock_http_resp.resp = mock_resp
+        mock_http_resp.data = '{"error": "INVALID_TOKEN"}'
+        mock_http_resp.status = 401
+        mock_http_resp.reason = 'Unauthorized'
+        mock_http_resp.getheaders.return_value = {}
 
         auth_exception = AuthorizationException(
-            status=401,
-            reason='Unauthorized',
             http_resp=mock_http_resp
         )
 
@@ -342,15 +340,13 @@ def test_poll_task_auth_failure_without_invalid_token(self, mock_sleep):
         task_runner = TaskRunner(worker=worker)
 
         # Create mock response with different error code
-        mock_resp = Mock()
-        mock_resp.text = '{"error": "FORBIDDEN"}'
-
         mock_http_resp = Mock()
-        mock_http_resp.resp = mock_resp
+        mock_http_resp.data = '{"error": "FORBIDDEN"}'
+        mock_http_resp.status = 403
+        mock_http_resp.reason = 'Forbidden'
+        mock_http_resp.getheaders.return_value = {}
 
         auth_exception = AuthorizationException(
-            status=403,
-            reason='Forbidden',
             http_resp=mock_http_resp
         )
 
@@ -420,15 +416,13 @@ def test_poll_task_with_metrics_on_auth_error(self):
         )
 
         # Create mock response with INVALID_TOKEN error
-        mock_resp = Mock()
-        mock_resp.text = '{"error": "INVALID_TOKEN"}'
-
         mock_http_resp = Mock()
-        mock_http_resp.resp = mock_resp
+        mock_http_resp.data = '{"error": "INVALID_TOKEN"}'
+        mock_http_resp.status = 401
+        mock_http_resp.reason = 'Unauthorized'
+        mock_http_resp.getheaders.return_value = {}
 
         auth_exception = AuthorizationException(
-            status=401,
-            reason='Unauthorized',
             http_resp=mock_http_resp
         )