{"record":{"id":"7efd4008625e8283","repo":"conductor-oss/conductor","slug":"a2a-stream-interrupted","errorCode":null,"errorMessage":"A2A stream interrupted","messagePattern":"A2A stream interrupted","errorType":"exception","errorClass":"IOException","httpStatus":null,"severity":"error","filePath":"agentspan/src/main/java/org/conductoross/conductor/ai/agentspan/a2a/A2ANativeAgentFacade.java","lineNumber":587,"sourceCode":"        event.put(\"final\", isFinal);\n        return event;\n    }\n\n    private Map<String, Object> artifactUpdate(A2ATask task, Artifact artifact) {\n        Map<String, Object> event = new HashMap<>();\n        event.put(\"kind\", \"artifact-update\");\n        event.put(\"taskId\", task.getId());\n        event.put(\"contextId\", task.getContextId());\n        event.put(\"artifact\", artifact);\n        return event;\n    }\n\n    private void sleep(long millis) throws IOException {\n        try {\n            Thread.sleep(millis);\n        } catch (InterruptedException e) {\n            Thread.currentThread().interrupt();\n            throw new IOException(\"A2A stream interrupted\", e);\n        }\n    }\n\n    private String baseUrl(String requestBaseUrl) {\n        String base =\n                properties.getPublicUrl() != null && !properties.getPublicUrl().isBlank()\n                        ? properties.getPublicUrl()\n                        : requestBaseUrl;\n        return base != null && base.endsWith(\"/\") ? base.substring(0, base.length() - 1) : base;\n    }\n\n    private String normalizedAgentBasePath() {\n        String path = properties.getAgentBasePath();\n        if (path == null || path.isBlank()) {\n            return \"/api/a2a/agent\";\n        }\n        String p = path.startsWith(\"/\") ? path : \"/\" + path;\n        return p.endsWith(\"/\") ? p.substring(0, p.length() - 1) : p;","sourceCodeStart":569,"sourceCodeEnd":605,"githubUrl":"https://github.com/conductor-oss/conductor/blob/cf7c3e4a8adfb158be778ab1ec525323c363cd3a/agentspan/src/main/java/org/conductoross/conductor/ai/agentspan/a2a/A2ANativeAgentFacade.java#L569-L605","documentation":"Error \"A2A stream interrupted\" thrown in conductor-oss/conductor.","triggerScenarios":"Thrown at agentspan/src/main/java/org/conductoross/conductor/ai/agentspan/a2a/A2ANativeAgentFacade.java:587 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Check network stability between Conductor and the A2A endpoint; the SSE stream was interrupted mid-flight.","Retry the agent execution; transient stream drops usually succeed on retry.","Verify the remote agent did not crash or time out while streaming events."],"exampleFix":null,"handlingStrategy":null,"validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"cf7c3e4a8adfb158be778ab1ec525323c363cd3a","analyzedAt":"2026-08-14T03:33:19.897Z","schemaVersion":2},"datasetVersion":"2026-08-14T05:17:29.042Z"}