Skip to content

Commit 5aaf02a

Browse files
committed
chore: Adds package-info file and sets package as @NullMarked (#336).
Update tck/src/main/java/io/a2a/tck/server/AgentExecutorProducer.java Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com> Update tck/src/main/java/io/a2a/tck/server/AgentCardProducer.java Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com> feat: Add some additional methods to TaskUpdater (#339) Thank you for opening a Pull Request! Before submitting your PR, there are a few things you can do to make sure it goes smoothly: - [x] Follow the [`CONTRIBUTING` Guide](../CONTRIBUTING.md). - [x] Make your Pull Request title in the <https://www.conventionalcommits.org/> specification. - Important Prefixes for [release-please](https://github.com/googleapis/release-please): - `fix:` which represents bug fixes, and correlates to a [SemVer](https://semver.org/) patch. - `feat:` represents a new feature, and correlates to a SemVer minor. - `feat!:`, or `fix!:`, `refactor!:`, etc., which represent a breaking change (indicated by the `!`) and will result in a SemVer major. - [x] Ensure the tests pass - [x] Appropriate READMEs were updated (if necessary) test: Disable flaky KafkaReplicationIntegrationTest (#346) Removes unused imports removes unused import
1 parent 47c906f commit 5aaf02a

File tree

4 files changed

+20
-1
lines changed

4 files changed

+20
-1
lines changed

extras/queue-manager-replicated/tests/src/test/java/io/a2a/extras/queuemanager/replicated/tests/KafkaReplicationIntegrationTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,13 +41,15 @@
4141
import org.eclipse.microprofile.reactive.messaging.Channel;
4242
import org.eclipse.microprofile.reactive.messaging.Emitter;
4343
import org.junit.jupiter.api.BeforeEach;
44+
import org.junit.jupiter.api.Disabled;
4445
import org.junit.jupiter.api.Test;
4546

4647
/**
4748
* Integration test for Kafka replication functionality.
4849
* Tests the full A2A message flow with Kafka replication verification.
4950
*/
5051
@QuarkusTest
52+
@Disabled
5153
public class KafkaReplicationIntegrationTest {
5254

5355
@Inject

server-common/src/main/java/io/a2a/server/tasks/TaskUpdater.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,14 @@ private void updateStatus(TaskState state, Message message, boolean isFinal) {
5858
}
5959
}
6060

61+
public String getContextId() {
62+
return this.contextId;
63+
}
64+
65+
public void addArtifact(List<Part<?>> parts) {
66+
addArtifact(parts, null, null, null);
67+
}
68+
6169
public void addArtifact(List<Part<?>> parts, String artifactId, String name, Map<String, Object> metadata) {
6270
addArtifact(parts, artifactId, name, metadata, null, null);
6371
}

tck/src/main/java/io/a2a/tck/server/AgentExecutorProducer.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
import io.a2a.spec.JSONRPCError;
1212
import io.a2a.spec.Task;
1313
import io.a2a.spec.TaskNotCancelableError;
14-
import io.a2a.spec.TaskNotFoundError;
1514
import io.a2a.spec.TaskState;
1615
import io.a2a.spec.TaskStatus;
1716
import io.a2a.spec.TaskStatusUpdateEvent;
Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
@NullMarked
2+
package io.a2a.tck.server;
3+
4+
import org.jspecify.annotations.NullMarked;
5+
6+
//The following had @Nullable annotation applied from JSpecify
7+
//AgentCardProducer.java getEnvOrDefault method,
8+
//AgentExecutorProducer.java execute method
9+
//
10+

0 commit comments

Comments
 (0)