@@ -26,10 +26,10 @@ def __init__(
2626 api_key : Optional [str ] = None ,
2727 max_concurrent_calls : int = 32 ,
2828 max_tokens : int = 512 ,
29- call_timeout_s : float = 30 .0 , # per request
30- gather_timeout_s : float = 120 .0 , # whole batch
31- max_retries : int = 2 ,
32- retry_base_delay_s : float = 0.5 ,
29+ call_timeout_s : float = 200 .0 , # per request
30+ gather_timeout_s : float = 500 .0 , # whole batch
31+ max_retries : int = 5 ,
32+ retry_base_delay_s : float = 1 ,
3333 client_kwargs : Optional [Dict [str , Any ]] = None ,
3434 call_kwargs : Optional [Dict [str , Any ]] = None ,
3535 config : Optional ["ExperimentConfig" ] = None ,
@@ -146,12 +146,8 @@ async def _ainvoke_with_retries(self, prompt: str, system_prompt: str) -> str:
146146 last_err = e
147147 if attempt < self .max_retries :
148148 delay = self .retry_base_delay_s * (2 ** attempt )
149- logger .warning (
150- "LLM call failed (%d/%d): %s — retrying in %.2fs" ,
151- attempt + 1 ,
152- self .max_retries + 1 ,
153- e ,
154- delay ,
149+ logger .error (
150+ f"LLM call failed ({ attempt + 1 } /{ self .max_retries + 1 } ): — retrying in { delay } s" , exc_info = e
155151 )
156152 await asyncio .sleep (delay )
157153 assert last_err is not None
0 commit comments