conductor-oss/conductor · error · IOException

A2A stream interrupted

Error message

A2A stream interrupted

What it means

Error "A2A stream interrupted" thrown in conductor-oss/conductor.

Source

Thrown at agentspan/src/main/java/org/conductoross/conductor/ai/agentspan/a2a/A2ANativeAgentFacade.java:587

        event.put("final", isFinal);
        return event;
    }

    private Map<String, Object> artifactUpdate(A2ATask task, Artifact artifact) {
        Map<String, Object> event = new HashMap<>();
        event.put("kind", "artifact-update");
        event.put("taskId", task.getId());
        event.put("contextId", task.getContextId());
        event.put("artifact", artifact);
        return event;
    }

    private void sleep(long millis) throws IOException {
        try {
            Thread.sleep(millis);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            throw new IOException("A2A stream interrupted", e);
        }
    }

    private String baseUrl(String requestBaseUrl) {
        String base =
                properties.getPublicUrl() != null && !properties.getPublicUrl().isBlank()
                        ? properties.getPublicUrl()
                        : requestBaseUrl;
        return base != null && base.endsWith("/") ? base.substring(0, base.length() - 1) : base;
    }

    private String normalizedAgentBasePath() {
        String path = properties.getAgentBasePath();
        if (path == null || path.isBlank()) {
            return "/api/a2a/agent";
        }
        String p = path.startsWith("/") ? path : "/" + path;
        return p.endsWith("/") ? p.substring(0, p.length() - 1) : p;

View on GitHub (pinned to cf7c3e4a8a)

Solutions

1. Check network stability between Conductor and the A2A endpoint; the SSE stream was interrupted mid-flight.
2. Retry the agent execution; transient stream drops usually succeed on retry.
3. Verify the remote agent did not crash or time out while streaming events.

When it happens

Trigger: Thrown at agentspan/src/main/java/org/conductoross/conductor/ai/agentspan/a2a/A2ANativeAgentFacade.java:587 when the library encounters an invalid state.

Common situations: See trigger scenarios.

AI-assisted analysis of conductor-oss/conductor@cf7c3e4a8a (2026-08-14). Data as JSON: /api/errors/7efd4008625e8283. Report an issue: GitHub.