feat: add Qwen-specific DashScope provider

Author: guima-why

babel.cfg

@@ -1,2 +1,2 @@
 [python: src/iac_code/**.py]
-keywords = translate_message CompletionEnrichmentError CompletionValidationError
+keywords = translate_message CompletionEnrichmentError CompletionValidationError ToolCallProtocolError UnsafeStreamProtocolError ProviderRequestLeaseError _localizable_message_id

src/iac_code/a2a/events.py

@@ -22,7 +22,8 @@
 
 from iac_code.a2a.artifacts import sanitize_public_artifact_text
 from iac_code.a2a.exposure import A2AExposureType, normalize_a2a_exposure_types
-from iac_code.i18n import _
+from iac_code.a2a.runtime_overrides import get_a2a_preferred_language
+from iac_code.i18n import translate_message
 from iac_code.mcp.progress import mcp_progress_metadata, mcp_progress_public_name
 from iac_code.services.permissions.audit import (
     build_input_summary,
@@ -122,6 +123,7 @@ async def publish_mcp_warnings(
         return
     from iac_code.mcp.manager import mcp_warning_metadata
 
+    language = get_a2a_preferred_language() or "en"
     for warning in warnings[pushed_count:]:
         warning_metadata = mcp_warning_metadata(warning)
         message = warning_metadata["message"]
@@ -133,7 +135,7 @@ async def publish_mcp_warnings(
             message=_agent_text_message(
                 task_id=task_id,
                 context_id=context_id,
-                text=_("MCP warning: {message}").format(message=message),
+                text=translate_message("MCP warning: {message}", language=language).format(message=message),
             ),
             metadata={
                 "iac_code": {
@@ -528,11 +530,17 @@ async def publish_stream_event(
         error_metadata: dict[str, Any] = {"retryable": event.is_retryable}
         if event.error_id:
             error_metadata["errorId"] = event.error_id
+        language = get_a2a_preferred_language() or "en"
         if event.is_retryable:
-            text = _("A temporary error occurred. Please retry.")
+            text = translate_message("A temporary error occurred. Please retry.", language=language)
             state = TaskState.TASK_STATE_INPUT_REQUIRED
         else:
-            raw = event.error or "Unknown error"
+            if event.i18n_message_id:
+                raw = translate_message(event.i18n_message_id, language=language).format(
+                    **(event.i18n_message_args or {})
+                )
+            else:
+                raw = event.error or translate_message("Unknown error", language=language)
             # Provider ErrorEvent is an explicitly retained compatibility
             # exception; ordinary A2A payloads are projected at the wire edge.
             text = sanitize_public_artifact_text(raw)[:_ERROR_TEXT_MAX_CHARS]

src/iac_code/agent/agent_loop.py

@@ -128,6 +128,11 @@ def stream_json_event_data(event: StreamEvent) -> dict[str, Any]:
         return data
 
     data = dataclasses.asdict(event)
+    if isinstance(event, MessageEndEvent):
+        data.pop("usage_attribution", None)
+    if isinstance(event, ErrorEvent):
+        data.pop("i18n_message_id", None)
+        data.pop("i18n_message_args", None)
     if isinstance(event, ToolResultEvent):
         data.pop("public_path_roots", None)
         if data.get("metadata") is None:

src/iac_code/cli/output_formats.py

@@ -45,7 +45,8 @@ msgstr "afterSequence muss eine nicht negative Ganzzahl sein"
 msgid "Unsafe artifact filename"
 msgstr "Unsicherer Artefaktdateiname"
 
-#: src/iac_code/a2a/artifacts.py src/iac_code/pipeline/engine/public_errors.py
+#: src/iac_code/a2a/artifacts.py src/iac_code/a2a/events.py
+#: src/iac_code/pipeline/engine/public_errors.py
 #: src/iac_code/utils/public_errors.py
 msgid "Unknown error"
 msgstr "Unbekannter Fehler"
@@ -6350,6 +6351,37 @@ msgstr ""
 "Kein API-Schlüssel für Anbieter '{provider}' konfiguriert (Modell: "
 "{model}). Führen Sie /auth aus, um die Konfiguration vorzunehmen."
 
+#: src/iac_code/providers/manager.py
+#, python-brace-format
+msgid "Provider request lease cannot be consumed from state {state}."
+msgstr ""
+"Die Lease der Provider-Anfrage kann im Zustand {state} nicht verwendet "
+"werden."
+
+#: src/iac_code/providers/manager.py
+msgid "Provider request lease was already released."
+msgstr "Die Lease der Provider-Anfrage wurde bereits freigegeben."
+
+#: src/iac_code/providers/manager.py
+msgid "Provider request lease belongs to a different manager."
+msgstr "Die Lease der Provider-Anfrage gehört zu einem anderen Manager."
+
+#: src/iac_code/providers/manager.py
+msgid "Explicit request lease system prompt does not match the streamed prompt."
+msgstr ""
+"Der System-Prompt der expliziten Anforderungs-Lease stimmt nicht mit dem "
+"Streaming-Prompt überein."
+
+#: src/iac_code/providers/manager.py
+msgid "Qwen replay ended before message completion."
+msgstr "Die Qwen-Wiederholung endete, bevor die Nachricht vollständig war."
+
+#: src/iac_code/providers/manager.py
+msgid "Explicit request lease system prompt does not match the completion prompt."
+msgstr ""
+"Der System-Prompt der expliziten Anforderungs-Lease stimmt nicht mit dem "
+"Completion-Prompt überein."
+
 #: src/iac_code/providers/openai_provider.py
 #, python-brace-format
 msgid ""
@@ -6372,6 +6404,74 @@ msgstr ""
 " Base URL korrekt ist (aktuell: {base_url}). Viele OpenAI-kompatible "
 "Endpunkte erfordern ein /v1-Suffix (z. B. {base_url}/v1)."
 
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen tool arguments must be a non-empty JSON object."
+msgstr "Qwen-Werkzeugargumente müssen ein nicht leeres JSON-Objekt sein."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen tool arguments are malformed JSON."
+msgstr "Qwen-Werkzeugargumente enthalten fehlerhaftes JSON."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen tool arguments must decode to an object."
+msgstr "Qwen-Werkzeugargumente müssen als Objekt dekodiert werden."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen native tool call is missing its ID or name."
+msgstr "Dem nativen Qwen-Werkzeugaufruf fehlt die ID oder der Name."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Invalid Qwen tool-call index."
+msgstr "Ungültiger Index für einen Qwen-Werkzeugaufruf."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Conflicting Qwen tool-call identity."
+msgstr "Widersprüchliche Identität des Qwen-Werkzeugaufrufs."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Conflicting Qwen tool-call name."
+msgstr "Widersprüchlicher Name des Qwen-Werkzeugaufrufs."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen tool-call arguments must be a string."
+msgstr "Die Argumente des Qwen-Werkzeugaufrufs müssen eine Zeichenfolge sein."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Duplicate Qwen tool-call identity."
+msgstr "Doppelte Identität des Qwen-Werkzeugaufrufs."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Ambiguous anonymous Qwen tool-call identity."
+msgstr "Mehrdeutige Identität eines anonymen Qwen-Werkzeugaufrufs."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Ambiguous anonymous Qwen tool-call fragment."
+msgstr "Mehrdeutiges Fragment eines anonymen Qwen-Werkzeugaufrufs."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Invalid Qwen tool-call JSON structure."
+msgstr "Ungültige JSON-Struktur des Qwen-Werkzeugaufrufs."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen response ended with tool_calls but no complete tool call."
+msgstr ""
+"Die Qwen-Antwort endete mit tool_calls, enthält aber keinen vollständigen"
+" Werkzeugaufruf."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen tool call is anonymous or nameless."
+msgstr "Der Qwen-Werkzeugaufruf ist anonym oder hat keinen Namen."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Duplicate Qwen tool-call ID."
+msgstr "Doppelte ID des Qwen-Werkzeugaufrufs."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen tool-call arguments ended before JSON was complete."
+msgstr ""
+"Die Argumente des Qwen-Werkzeugaufrufs endeten, bevor das JSON "
+"vollständig war."
+
 #: src/iac_code/providers/registry.py
 msgid "Alibaba Cloud Bailian"
 msgstr "Alibaba Cloud Bailian"
@@ -6448,6 +6548,28 @@ msgstr "Volcengine CodingPlan"
 msgid "Anthropic Compatible"
 msgstr "Anthropic-kompatibel"
 
+#: src/iac_code/providers/streaming.py
+msgid "Qwen thinking-tag candidate exceeded the safety limit."
+msgstr ""
+"Der Qwen-Kandidat für ein thinking-Tag hat das Sicherheitslimit "
+"überschritten."
+
+#: src/iac_code/providers/streaming.py
+msgid "Qwen emitted an unsafe or conflicting thinking-tag block."
+msgstr ""
+"Qwen hat einen unsicheren oder widersprüchlichen thinking-Tag-Block "
+"ausgegeben."
+
+#: src/iac_code/providers/streaming.py
+msgid "Qwen emitted a stray thinking closing tag."
+msgstr "Qwen hat ein einzelnes schließendes thinking-Tag ausgegeben."
+
+#: src/iac_code/providers/streaming.py
+msgid "Qwen emitted a closing thinking tag without a valid native tool call."
+msgstr ""
+"Qwen hat ein schließendes thinking-Tag ohne gültigen nativen "
+"Werkzeugaufruf ausgegeben."
+
 #: src/iac_code/services/agent_factory.py
 #, python-brace-format
 msgid "MCP server {server!r} connection failed: {error}"

src/iac_code/i18n/locales/de/LC_MESSAGES/messages.po

@@ -46,7 +46,8 @@ msgstr "afterSequence debe ser un entero no negativo"
 msgid "Unsafe artifact filename"
 msgstr "Nombre de archivo de artefacto no seguro"
 
-#: src/iac_code/a2a/artifacts.py src/iac_code/pipeline/engine/public_errors.py
+#: src/iac_code/a2a/artifacts.py src/iac_code/a2a/events.py
+#: src/iac_code/pipeline/engine/public_errors.py
 #: src/iac_code/utils/public_errors.py
 msgid "Unknown error"
 msgstr "Error desconocido"
@@ -6300,6 +6301,37 @@ msgstr ""
 "No se ha configurado una clave API para el proveedor '{provider}' "
 "(modelo: {model}). Ejecute /auth para configurar."
 
+#: src/iac_code/providers/manager.py
+#, python-brace-format
+msgid "Provider request lease cannot be consumed from state {state}."
+msgstr ""
+"La reserva de la solicitud al proveedor no se puede consumir desde el "
+"estado {state}."
+
+#: src/iac_code/providers/manager.py
+msgid "Provider request lease was already released."
+msgstr "La reserva de la solicitud al proveedor ya se liberó."
+
+#: src/iac_code/providers/manager.py
+msgid "Provider request lease belongs to a different manager."
+msgstr "La reserva de la solicitud al proveedor pertenece a otro gestor."
+
+#: src/iac_code/providers/manager.py
+msgid "Explicit request lease system prompt does not match the streamed prompt."
+msgstr ""
+"El prompt del sistema de la reserva de solicitud explícita no coincide "
+"con el prompt de streaming."
+
+#: src/iac_code/providers/manager.py
+msgid "Qwen replay ended before message completion."
+msgstr "La repetición de Qwen terminó antes de completarse el mensaje."
+
+#: src/iac_code/providers/manager.py
+msgid "Explicit request lease system prompt does not match the completion prompt."
+msgstr ""
+"El prompt del sistema de la reserva de solicitud explícita no coincide "
+"con el prompt de finalización."
+
 #: src/iac_code/providers/openai_provider.py
 #, python-brace-format
 msgid ""
@@ -6322,6 +6354,74 @@ msgstr ""
 " correcta (actual: {base_url}). Muchos endpoints compatibles con OpenAI "
 "requieren el sufijo /v1 (p. ej., {base_url}/v1)."
 
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen tool arguments must be a non-empty JSON object."
+msgstr "Los argumentos de herramienta de Qwen deben ser un objeto JSON no vacío."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen tool arguments are malformed JSON."
+msgstr "Los argumentos de herramienta de Qwen contienen JSON no válido."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen tool arguments must decode to an object."
+msgstr "Los argumentos de herramienta de Qwen deben decodificarse como un objeto."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen native tool call is missing its ID or name."
+msgstr "A la llamada nativa a herramienta de Qwen le falta el ID o el nombre."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Invalid Qwen tool-call index."
+msgstr "El índice de la llamada a herramienta de Qwen no es válido."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Conflicting Qwen tool-call identity."
+msgstr "La identidad de la llamada a herramienta de Qwen está en conflicto."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Conflicting Qwen tool-call name."
+msgstr "El nombre de la llamada a herramienta de Qwen está en conflicto."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen tool-call arguments must be a string."
+msgstr "Los argumentos de la llamada a herramienta de Qwen deben ser una cadena."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Duplicate Qwen tool-call identity."
+msgstr "La identidad de la llamada a herramienta de Qwen está duplicada."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Ambiguous anonymous Qwen tool-call identity."
+msgstr "La identidad de una llamada anónima a herramienta de Qwen es ambigua."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Ambiguous anonymous Qwen tool-call fragment."
+msgstr "El fragmento de una llamada anónima a herramienta de Qwen es ambiguo."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Invalid Qwen tool-call JSON structure."
+msgstr "La estructura JSON de la llamada a herramienta de Qwen no es válida."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen response ended with tool_calls but no complete tool call."
+msgstr ""
+"La respuesta de Qwen terminó con tool_calls, pero no contiene ninguna "
+"llamada a herramienta completa."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen tool call is anonymous or nameless."
+msgstr "La llamada a herramienta de Qwen es anónima o no tiene nombre."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Duplicate Qwen tool-call ID."
+msgstr "El ID de la llamada a herramienta de Qwen está duplicado."
+
+#: src/iac_code/providers/qwen_tool_call_parser.py
+msgid "Qwen tool-call arguments ended before JSON was complete."
+msgstr ""
+"Los argumentos de la llamada a herramienta de Qwen terminaron antes de "
+"que se completara el JSON."
+
 #: src/iac_code/providers/registry.py
 msgid "Alibaba Cloud Bailian"
 msgstr "Alibaba Cloud Bailian"
@@ -6398,6 +6498,24 @@ msgstr "Volcengine CodingPlan"
 msgid "Anthropic Compatible"
 msgstr "Compatible con Anthropic"
 
+#: src/iac_code/providers/streaming.py
+msgid "Qwen thinking-tag candidate exceeded the safety limit."
+msgstr "El candidato a etiqueta thinking de Qwen superó el límite de seguridad."
+
+#: src/iac_code/providers/streaming.py
+msgid "Qwen emitted an unsafe or conflicting thinking-tag block."
+msgstr "Qwen generó un bloque de etiquetas thinking no seguro o en conflicto."
+
+#: src/iac_code/providers/streaming.py
+msgid "Qwen emitted a stray thinking closing tag."
+msgstr "Qwen generó una etiqueta de cierre thinking aislada."
+
+#: src/iac_code/providers/streaming.py
+msgid "Qwen emitted a closing thinking tag without a valid native tool call."
+msgstr ""
+"Qwen generó una etiqueta de cierre thinking sin una llamada nativa a "
+"herramienta válida."
+
 #: src/iac_code/services/agent_factory.py
 #, python-brace-format
 msgid "MCP server {server!r} connection failed: {error}"