We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 63669b9 commit 1413cd7Copy full SHA for 1413cd7
servicex/servicex_adapter.py
@@ -304,9 +304,12 @@ async def get_transformation_results(
304
if later_than:
305
params["later_than"] = later_than.isoformat()
306
307
- async with AsyncClient() as session:
+ retry_options = Retry(total=3, backoff_factor=10)
308
+ async with AsyncClient(
309
+ transport=RetryTransport(retry=retry_options), timeout=_timeout
310
+ ) as session:
311
r = await session.get(headers=headers, url=url, params=params)
- if r.status_code == 403:
312
+ if r.status_code in [401, 403]:
313
raise AuthorizationError(
314
f"Not authorized to access serviceX at {self.url}"
315
)
0 commit comments