Step 4A-6-C-R3.2.1 Executor Direct Transport Correction

task_executor.py

@@ -1,5 +1,5 @@
 # -*- coding: utf-8 -*-
-"""SmartPaper R3.1 independent task executor.
+"""SmartPaper R3.2.1 independent task executor.
 
 Bootstrap is intentionally lightweight: the child process validates the local
 request, claims the D1 task, writes a local claim handshake, and only then
@@ -147,16 +147,52 @@ class ExecutorApi:
             "Authorization": f"Bearer {_service_key()}",
             "Accept": "application/json",
             "Content-Type": "application/json",
-            "User-Agent": "SmartPaper-R3.1-Executor/1.0",
+            "User-Agent": "SmartPaper-R3.2.1-Executor/1.0",
         }
+        # HF Spaces can expose environment proxy settings that are less reliable
+        # for direct TLS handshakes to workers.dev.  Reuse the proven SmartPaper
+        # transport policy: direct networking first, environment-aware networking
+        # only as a transport fallback. Business/HTTP errors never trigger fallback.
+        self._direct_session = requests.Session()
+        self._direct_session.trust_env = False
+        self._environment_session = requests.Session()
 
     def post(self, path: str, payload: dict, *, timeout=20) -> dict:
-        response = requests.post(
-            self.origin + path,
-            headers=self.headers,
-            json=payload,
-            timeout=timeout,
+        url = self.origin + path
+        response = None
+        last_transport_error = None
+        transports = (
+            ("direct", self._direct_session),
+            ("environment", self._environment_session),
         )
+        for index, (transport_name, session) in enumerate(transports):
+            try:
+                response = session.post(
+                    url,
+                    headers=self.headers,
+                    json=payload,
+                    timeout=timeout,
+                )
+                break
+            except (
+                requests.exceptions.SSLError,
+                requests.exceptions.Timeout,
+                requests.exceptions.ConnectionError,
+            ) as exc:
+                last_transport_error = exc
+                if index == 0:
+                    logging.warning(
+                        "[SP_EXECUTOR] transport_fallback path=%s from=direct to=environment error=%s",
+                        path, type(exc).__name__,
+                    )
+                    continue
+                raise
+
+        if response is None:
+            if last_transport_error is not None:
+                raise last_transport_error
+            raise RuntimeError("executor_transport_unavailable")
+
         try:
             data = response.json()
         except Exception as exc: