graph: Fix event leakage between concurrent nodes (#425)

Author: nomand-zc

graph/state_graph.go

@@ -17,6 +17,7 @@ import (
 	"reflect"
 	"time"
 
+	"github.com/google/uuid"
 	"go.opentelemetry.io/otel/attribute"
 	oteltrace "go.opentelemetry.io/otel/trace"
 
@@ -1344,10 +1345,12 @@ func buildAgentInvocation(ctx context.Context, state State, targetAgent agent.Ag
 
 	// clone a new Invocation from parent.
 	if parentInvocation, ok := agent.InvocationFromContext(ctx); ok && parentInvocation != nil {
+		filterKey := parentInvocation.GetEventFilterKey() + agent.EventFilterKeyDelimiter + targetAgent.Info().Name + uuid.NewString()
 		invocation := parentInvocation.Clone(
 			agent.WithInvocationAgent(targetAgent),
 			agent.WithInvocationMessage(model.NewUserMessage(userInput)),
 			agent.WithInvocationRunOptions(agent.RunOptions{RuntimeState: state}),
+			agent.WithInvocationEventFilterKey(filterKey),
 		)
 		return invocation
 	}
@@ -1357,6 +1360,7 @@ func buildAgentInvocation(ctx context.Context, state State, targetAgent agent.Ag
 		agent.WithInvocationRunOptions(agent.RunOptions{RuntimeState: state}),
 		agent.WithInvocationMessage(model.NewUserMessage(userInput)),
 		agent.WithInvocationSession(sessionData),
+		agent.WithInvocationEventFilterKey(targetAgent.Info().Name+uuid.NewString()),
 	)
 	return invocation
 }