Extend timeout for httpx put in submission (#632)

Author: ponyisi

servicex/servicex_adapter.py

@@ -31,7 +31,7 @@
 from typing import Optional, Dict, List
 from dataclasses import dataclass
 
-from httpx import AsyncClient, Response
+from httpx import AsyncClient, Response, Timeout
 from json import JSONDecodeError
 from httpx_retries import RetryTransport, Retry
 from google.auth import jwt
@@ -71,6 +71,9 @@ async def _extract_message(r: Response):
     return error_message
 
 
+_timeout = Timeout(10, read=300)
+
+
 class ServiceXAdapter:
     def __init__(self, url: str, refresh_token: Optional[str] = None):
         self.url = url
@@ -349,7 +352,9 @@ async def cancel_transform(self, transform_id=None):
     async def submit_transform(self, transform_request: TransformRequest) -> str:
         headers = await self._get_authorization()
         retry_options = Retry(total=3, backoff_factor=30)
-        async with AsyncClient(transport=RetryTransport(retry=retry_options)) as client:
+        async with AsyncClient(
+            transport=RetryTransport(retry=retry_options), timeout=_timeout
+        ) as client:
             r = await client.post(
                 url=f"{self.url}/servicex/transformation",
                 headers=headers,