(ctx context.Context, info *callbacks.RunInfo, input *adk.AgentCallbackInput)
| 789 | ) |
| 790 | |
| 791 | func (d defaultDataParser) parseAgentInput(ctx context.Context, info *callbacks.RunInfo, input *adk.AgentCallbackInput) map[string]any { |
| 792 | if info == nil || input == nil { |
| 793 | return nil |
| 794 | } |
| 795 | |
| 796 | tags := make(spanTags) |
| 797 | |
| 798 | if input.Input != nil { |
| 799 | tags.set(attrKeyRunMode, "run") |
| 800 | tags.set(tracespec.Input, parseAny(ctx, input.Input.Messages, false)) |
| 801 | tags.set(tracespec.Stream, input.Input.EnableStreaming) |
| 802 | } else if input.ResumeInfo != nil { |
| 803 | tags.set(attrKeyRunMode, "resume") |
| 804 | tags.set(tracespec.Input, input.ResumeInfo) |
| 805 | tags.set(tracespec.Stream, input.ResumeInfo.EnableStreaming) |
| 806 | } |
| 807 | |
| 808 | tags.set(attrKeyAgentName, info.Name) |
| 809 | |
| 810 | return tags |
| 811 | } |
| 812 | |
| 813 | func (d defaultDataParser) parseAgentOutput(ctx context.Context, info *callbacks.RunInfo, output *adk.AgentCallbackOutput) map[string]any { |
| 814 | if info == nil || output == nil || output.Events == nil { |
no test coverage detected