Update github.com/a2aproject/a2a-go v0.3.3 -> v0.3.4

dgageot · dgageot · commit ab55b90ff7ce · 2026-01-16T08:02:49.000+01:00
Update the Read() method signature to include TaskVersion as required
by the new API. Also add WriteVersioned() method to satisfy the Queue
interface.

Assisted-By: cagent
diff --git a/go.mod b/go.mod
@@ -11,7 +11,7 @@ require (
 	connectrpc.com/connect v1.19.1
 	github.com/JohannesKaufmann/html-to-markdown/v2 v2.5.0
 	github.com/Microsoft/go-winio v0.6.2
-	github.com/a2aproject/a2a-go v0.3.3
+	github.com/a2aproject/a2a-go v0.3.4
 	github.com/alecthomas/chroma/v2 v2.22.0
 	github.com/alpkeskin/gotoon v0.1.1
 	github.com/anthropics/anthropic-sdk-go v1.19.0
diff --git a/go.sum b/go.sum
@@ -31,6 +31,8 @@ github.com/RoaringBitmap/roaring/v2 v2.4.5 h1:uGrrMreGjvAtTBobc0g5IrW1D5ldxDQYe2
 github.com/RoaringBitmap/roaring/v2 v2.4.5/go.mod h1:FiJcsfkGje/nZBZgCu0ZxCPOKD/hVXDS2dXi7/eUFE0=
 github.com/a2aproject/a2a-go v0.3.3 h1:NqGDw2c8hCSW3/9MakeeRpw5yCZUUmW2Y/yINV15GwQ=
 github.com/a2aproject/a2a-go v0.3.3/go.mod h1:8C0O6lsfR7zWFEqVZz/+zWCoxe8gSWpknEpqm/Vgj3E=
+github.com/a2aproject/a2a-go v0.3.4 h1:rSMR/IryydWkIjtxDLZCVgSc3RrVF4eHrycKlBC/WE0=
+github.com/a2aproject/a2a-go v0.3.4/go.mod h1:8C0O6lsfR7zWFEqVZz/+zWCoxe8gSWpknEpqm/Vgj3E=
 github.com/alecthomas/assert/v2 v2.11.0 h1:2Q9r3ki8+JYXvGsDyBXwH3LcJ+WK5D0gc5E8vS6K3D0=
 github.com/alecthomas/assert/v2 v2.11.0/go.mod h1:Bze95FyfUr7x34QZrjL+XP+0qgp/zg8yS+TtBj1WA3k=
 github.com/alecthomas/chroma/v2 v2.22.0 h1:PqEhf+ezz5F5owoDeOUKFzW+W3ZJDShNCaHg4sZuItI=
diff --git a/pkg/a2a/executor_wrapper.go b/pkg/a2a/executor_wrapper.go
@@ -49,10 +49,14 @@ func (fq *fixingQueue) Write(ctx context.Context, event a2a.Event) error {
 	return fq.queue.Write(ctx, event)
 }
 
-func (fq *fixingQueue) Read(ctx context.Context) (a2a.Event, error) {
+func (fq *fixingQueue) Read(ctx context.Context) (a2a.Event, a2a.TaskVersion, error) {
 	return fq.queue.Read(ctx)
 }
 
+func (fq *fixingQueue) WriteVersioned(ctx context.Context, event a2a.Event, version a2a.TaskVersion) error {
+	return fq.queue.WriteVersioned(ctx, event, version)
+}
+
 func (fq *fixingQueue) Close() error {
 	return fq.queue.Close()
 }
diff --git a/pkg/a2a/executor_wrapper_test.go b/pkg/a2a/executor_wrapper_test.go
@@ -20,8 +20,13 @@ func (m *mockQueue) Write(_ context.Context, event a2a.Event) error {
 	return nil
 }
 
-func (m *mockQueue) Read(context.Context) (a2a.Event, error) {
-	return nil, nil
+func (m *mockQueue) Read(context.Context) (a2a.Event, a2a.TaskVersion, error) {
+	return nil, a2a.TaskVersionMissing, nil
+}
+
+func (m *mockQueue) WriteVersioned(_ context.Context, event a2a.Event, _ a2a.TaskVersion) error {
+	m.events = append(m.events, event)
+	return nil
 }
 
 func (m *mockQueue) Close() error {

Original file line number	Diff line number	Diff line change
`@@ -49,10 +49,14 @@ func (fq *fixingQueue) Write(ctx context.Context, event a2a.Event) error {`
`49`	`49`	`return fq.queue.Write(ctx, event)`
`50`	`50`	`}`
`51`	`51`
`52`		`-func (fq *fixingQueue) Read(ctx context.Context) (a2a.Event, error) {`
	`52`	`+func (fq *fixingQueue) Read(ctx context.Context) (a2a.Event, a2a.TaskVersion, error) {`
`53`	`53`	`return fq.queue.Read(ctx)`
`54`	`54`	`}`
`55`	`55`
	`56`	`+func (fq *fixingQueue) WriteVersioned(ctx context.Context, event a2a.Event, version a2a.TaskVersion) error {`
	`57`	`+ return fq.queue.WriteVersioned(ctx, event, version)`
	`58`	`+}`
	`59`	`+`
`56`	`60`	`func (fq *fixingQueue) Close() error {`
`57`	`61`	`return fq.queue.Close()`
`58`	`62`	`}`
Original file line number	Diff line number	Diff line change
`@@ -20,8 +20,13 @@ func (m *mockQueue) Write(_ context.Context, event a2a.Event) error {`
`20`	`20`	`return nil`
`21`	`21`	`}`
`22`	`22`
`23`		`-func (m *mockQueue) Read(context.Context) (a2a.Event, error) {`
`24`		`- return nil, nil`
	`23`	`+func (m *mockQueue) Read(context.Context) (a2a.Event, a2a.TaskVersion, error) {`
	`24`	`+ return nil, a2a.TaskVersionMissing, nil`
	`25`	`+}`
	`26`	`+`
	`27`	`+func (m *mockQueue) WriteVersioned(_ context.Context, event a2a.Event, _ a2a.TaskVersion) error {`
	`28`	`+ m.events = append(m.events, event)`
	`29`	`+ return nil`
`25`	`30`	`}`
`26`	`31`
`27`	`32`	`func (m *mockQueue) Close() error {`