Handle wrapped prompt send timeouts and empty responses in red team retry logic (#43977)

* Handle wrapped prompt send timeouts and empty responses in red team retry logic

* code review comments

Author: slister1001

sdk/evaluation/azure-ai-evaluation/azure/ai/evaluation/red_team/_orchestrator_manager.py

@@ -58,6 +58,7 @@ def network_retry_decorator(retry_config, logger, strategy_name, risk_category_n
     def decorator(func):
         @retry(**retry_config["network_retry"])
         async def wrapper(*args, **kwargs):
+            prompt_detail = f" for prompt {prompt_idx}" if prompt_idx is not None else ""
             try:
                 return await func(*args, **kwargs)
             except (
@@ -72,12 +73,59 @@ async def wrapper(*args, **kwargs):
                 httpcore.ReadTimeout,
                 httpx.HTTPStatusError,
             ) as e:
-                prompt_detail = f" for prompt {prompt_idx}" if prompt_idx is not None else ""
                 logger.warning(
-                    f"Network error{prompt_detail} for {strategy_name}/{risk_category_name}: {type(e).__name__}: {str(e)}"
+                    f"Retrying network error{prompt_detail} for {strategy_name}/{risk_category_name}: {type(e).__name__}: {str(e)}"
                 )
                 await asyncio.sleep(2)
                 raise
+            except ValueError as e:
+                # Treat missing converted prompt text as a transient transport issue so tenacity will retry.
+                if "Converted prompt text is None" in str(e):
+                    logger.warning(
+                        f"Endpoint produced empty converted prompt{prompt_detail} for {strategy_name}/{risk_category_name}; retrying."
+                    )
+                    await asyncio.sleep(2)
+                    raise httpx.HTTPError(
+                        "Converted prompt text is None; treating as transient endpoint failure"
+                    ) from e
+                raise
+            except Exception as e:
+                message = str(e)
+                cause = e.__cause__
+
+                def _is_network_cause(exc: BaseException) -> bool:
+                    return isinstance(
+                        exc,
+                        (
+                            httpx.HTTPError,
+                            httpx.ConnectTimeout,
+                            httpx.ReadTimeout,
+                            httpcore.ReadTimeout,
+                            asyncio.TimeoutError,
+                            ConnectionError,
+                            TimeoutError,
+                            OSError,
+                        ),
+                    )
+
+                def _is_converted_prompt_error(exc: BaseException) -> bool:
+                    return isinstance(exc, ValueError) and "Converted prompt text is None" in str(exc)
+
+                if (
+                    "Error sending prompt with conversation ID" in message
+                    and cause
+                    and (_is_network_cause(cause) or _is_converted_prompt_error(cause))
+                ):
+                    logger.warning(
+                        f"Wrapped network error{prompt_detail} for {strategy_name}/{risk_category_name}: {message}. Retrying."
+                    )
+                    await asyncio.sleep(2)
+                    if _is_converted_prompt_error(cause):
+                        raise httpx.HTTPError(
+                            "Converted prompt text is None; treating as transient endpoint failure"
+                        ) from cause
+                    raise httpx.HTTPError(message) from cause
+                raise
 
         return wrapper