Skip to content

fix: reject SendMessage to tasks in terminal state with UnsupportedOperationError#746

Open
brucearctor wants to merge 1 commit intoa2aproject:mainfrom
brucearctor:fix/terminal-task-send-message-guard
Open

fix: reject SendMessage to tasks in terminal state with UnsupportedOperationError#746
brucearctor wants to merge 1 commit intoa2aproject:mainfrom
brucearctor:fix/terminal-task-send-message-guard

Conversation

@brucearctor
Copy link

Summary

SendMessage to a task in a terminal state (completed, canceled, rejected, failed) succeeds instead of returning UnsupportedOperationError. Fails on all three transports (JSON-RPC, gRPC, HTTP+JSON).

Requirement

  • ID: CORE-SEND-002
  • Section: 3.1.1 — SendMessage rejects messages to terminal tasks
  • Level: MUST

Changes

Added a guard in DefaultRequestHandler.initMessageSend(), which is invoked by both onMessageSend (blocking) and onMessageSendStream (streaming). The guard checks whether the referenced task is in a final state before forwarding the message to AgentExecutor:

if (task.status().state().isFinal()) {
    throw new UnsupportedOperationError(null,
        "Cannot send message to task " + task.id() +
        " - task is in a terminal state: " + task.status().state(), null);
}

Tests

Added 5 new tests in DefaultRequestHandlerTest:

  • testSendMessage_ToCompletedTask_ThrowsUnsupportedOperationError
  • testSendMessage_ToCanceledTask_ThrowsUnsupportedOperationError
  • testSendMessage_ToRejectedTask_ThrowsUnsupportedOperationError
  • testSendMessage_ToFailedTask_ThrowsUnsupportedOperationError
  • testSendMessageStream_ToCompletedTask_ThrowsUnsupportedOperationError (streaming path)

All 11 tests in DefaultRequestHandlerTest pass.

This fixes #741

…erationError

Per A2A spec section 3.1.1 (CORE-SEND-002), the SDK MUST return an
UnsupportedOperationError when a client attempts to send a message to
a task that is already in a terminal state (completed, canceled,
rejected, or failed).

The guard is added in DefaultRequestHandler.initMessageSend(), which
is called by both onMessageSend (blocking) and onMessageSendStream
(streaming). This ensures the check happens before the message is
forwarded to the AgentExecutor on all three transports (JSON-RPC,
gRPC, HTTP+JSON).

This fixes a2aproject#741
@gemini-code-assist
Copy link
Contributor

Summary of Changes

Hello, I'm Gemini Code Assist1! I'm currently reviewing this pull request and will post my feedback shortly. In the meantime, here's a summary to help you and other reviewers quickly get up to speed!

This pull request addresses a critical compliance issue by ensuring that the system correctly rejects attempts to send messages to tasks that have reached a final, non-active state. This change aligns the system's behavior with the A2A specification, improving robustness and predictability by preventing operations on tasks that are no longer capable of processing new messages.

Highlights

  • Error Handling for Terminal Tasks: Implemented a guard in DefaultRequestHandler.initMessageSend() to prevent sending messages to tasks that are already in a terminal state (completed, canceled, rejected, or failed), ensuring an UnsupportedOperationError is thrown as per specification CORE-SEND-002.
  • Comprehensive Test Coverage: Added five new unit tests in DefaultRequestHandlerTest to validate the correct behavior for SendMessage and SendMessageStream when targeting tasks in various terminal states.
Changelog
  • server-common/src/main/java/io/a2a/server/requesthandlers/DefaultRequestHandler.java
    • Modified the initMessageSend method signature to declare throws A2AError.
    • Added a conditional check within initMessageSend to throw an UnsupportedOperationError if the target task's status indicates a final state.
  • server-common/src/test/java/io/a2a/server/requesthandlers/DefaultRequestHandlerTest.java
    • Imported the UnsupportedOperationError class.
    • Updated the testRejectMismatchingContextId test to ensure the task is not in a terminal state, preventing the new terminal state guard from firing prematurely.
    • Introduced a private helper method assertSendMessageToTerminalStateThrows to encapsulate common test logic for terminal states.
    • Added testSendMessage_ToCompletedTask_ThrowsUnsupportedOperationError to verify rejection for completed tasks.
    • Added testSendMessage_ToCanceledTask_ThrowsUnsupportedOperationError to verify rejection for canceled tasks.
    • Added testSendMessage_ToRejectedTask_ThrowsUnsupportedOperationError to verify rejection for rejected tasks.
    • Added testSendMessage_ToFailedTask_ThrowsUnsupportedOperationError to verify rejection for failed tasks.
    • Added testSendMessageStream_ToCompletedTask_ThrowsUnsupportedOperationError to test streaming message rejection for completed tasks.
Activity
Using Gemini Code Assist

The full guide for Gemini Code Assist can be found on our documentation page, here are some quick tips.

Invoking Gemini

You can request assistance from Gemini at any point by creating a comment using either /gemini <command> or @gemini-code-assist <command>. Below is a summary of the supported commands on the current page.

Feature Command Description
Code Review /gemini review Performs a code review for the current pull request in its current state.
Pull Request Summary /gemini summary Provides a summary of the current pull request in its current state.
Comment @gemini-code-assist Responds in comments when explicitly tagged, both in pull request comments and review comments.
Help /gemini help Displays a list of available commands.

Customization

To customize Gemini Code Assist for GitHub experience, repository maintainers can create a configuration file and/or provide a custom code review style guide (such as PEP-8 for Python) by creating and adding files to a .gemini/ folder in the base of the repository. Detailed instructions can be found here.

Limitations & Feedback

Gemini Code Assist may make mistakes. Please leave feedback on any instances where its feedback is incorrect or counter productive. You can react with 👍 and 👎 on @gemini-code-assist comments. If you're interested in giving your feedback about your experience with Gemini Code Assist for GitHub and other Google products, sign up here.

You can also get AI-powered code generation, chat, as well as code reviews directly in the IDE at no cost with the Gemini Code Assist IDE Extension.

Footnotes

  1. Review the Privacy Notices, Generative AI Prohibited Use Policy, Terms of Service, and learn how to configure Gemini Code Assist in GitHub here. Gemini can make mistakes, so double check it and use code with caution.

Copy link
Contributor

@gemini-code-assist gemini-code-assist bot left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Code Review

This pull request implements a new validation rule in DefaultRequestHandler.java to prevent sending messages to tasks that are in a terminal state (completed, canceled, rejected, or failed), as per A2A spec section 3.1.1 (CORE-SEND-002). The initMessageSend method now throws an UnsupportedOperationError in such cases, and its signature has been updated to declare throws A2AError. Comprehensive unit tests have been added and modified in DefaultRequestHandlerTest.java to verify this behavior for all terminal states and for both standard and streaming message sending operations, ensuring the correct error is thrown.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Bug]: It must not be possible to send a message to a task is in a terminal state

2 participants