feat: implement streaming support in to_a2a for issue #4240#4230
feat: implement streaming support in to_a2a for issue #4240#4230sanjeevamk1 wants to merge 6 commits intogoogle:mainfrom
Conversation
Summary of ChangesHello @sanjeevamk1, 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 enhances the Highlights
🧠 New Feature in Public Preview: You can now enable Memory to help Gemini Code Assist learn from your team's feedback. This makes future code reviews more consistent and personalized to your project's style. Click here to enable Memory in your admin console. Using Gemini Code AssistThe 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
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 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
|
|
Response from ADK Triaging Agent Hello @sanjeevamk1, thank you for creating this PR! To help reviewers understand and evaluate your contribution, could you please fill out the pull request template in the description? Specifically, please provide the following:
This information is crucial for an efficient review process. You can find more details in our contribution guide. Thanks! |
There was a problem hiding this comment.
Code Review
This pull request introduces streaming support for the to_a2a function. The implementation approach is sound, but I've identified a critical issue with a shadowed import that will likely lead to runtime failures. Additionally, there's an opportunity to improve maintainability by addressing significant code duplication in the new request converter. I've also pointed out a minor typo. Please review my comments for details.
Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>
|
H @sanjeevamk1, Thank you for your contribution! We appreciate you taking the time to submit this pull request. Can you address the comment and also fix the formatting errors before we can proceed with the review. You can use autoformat.sh for formatting errors. |
|
/gemini review |
|
Warning You have reached your daily quota limit. Please wait up to 24 hours and I will start processing your requests again! |
zeroasterisk
left a comment
There was a problem hiding this comment.
Please remove all the "linter" artifacts from this PR.
Please implement a unit test and integration test.
I'm generally ok with this, though I am loathe to change the function signature unless I have to.
Challenge 1: Can you get the same functionality with a custom runner you pass into to_a2a()?
Challenge 2: Is this really sufficient for A2A, which I know supports many other types of transports or data bindings? It seems like you are solving for one more, but not all, and thus the interface would be fragile.
Please reduce the scope of this PR and answer my challenges to move forward.
| MOOD_INSTRUCTIONS = { | ||
| "full": """ | ||
| "full": ( | ||
| """ |
There was a problem hiding this comment.
these are a lot of what looks like unrelated linter changes.
please remove them, and only submit the PR with the lines that actually matter to this set of changes.
| f" {cached_analysis['cache_utilization_ratio_percent']:.1f}%" | ||
| f" ({cached_analysis['requests_with_cache_hits']}/{cached_analysis['total_requests']} requests)" | ||
| f" ({cached_analysis['requests_with_cache_hits']}/{cached_analysis['total_requests']}" | ||
| " requests)" |
There was a problem hiding this comment.
these are a lot of what looks like unrelated linter changes.
please remove them, and only submit the PR with the lines that actually matter to this set of changes.
| – includes Python API reference from HTML files | ||
| – includes adk-python repository README | ||
| """ | ||
|
|
There was a problem hiding this comment.
these are a lot of what looks like unrelated linter changes.
please remove them, and only submit the PR with the lines that actually matter to this set of changes.
| """ | ||
| This agent aims to test the Langchain tool with Langchain's StructuredTool | ||
| """ | ||
|
|
There was a problem hiding this comment.
these are a lot of what looks like unrelated linter changes.
please remove them, and only submit the PR with the lines that actually matter to this set of changes.
| in session state. | ||
| """ | ||
|
|
||
|
|
There was a problem hiding this comment.
these are a lot of what looks like unrelated linter changes.
please remove them, and only submit the PR with the lines that actually matter to this set of changes.
| 'Turn tokens:' | ||
| f' {event.usage_metadata.total_token_count} (prompt={event.usage_metadata.prompt_token_count},' | ||
| f'Turn tokens: {event.usage_metadata.total_token_count}' | ||
| f' (prompt={event.usage_metadata.prompt_token_count},' |
There was a problem hiding this comment.
i actually like this change, but it's unrelated to the focus of this PR
| "$ref": f"#/components/schemas/{action_display_name}_Request" | ||
| "$ref": ( | ||
| f"#/components/schemas/{action_display_name}_Request" | ||
| ) |
There was a problem hiding this comment.
these are a lot of what looks like unrelated linter changes.
please remove them, and only submit the PR with the lines that actually matter to this set of changes.
| # limitations under the License. | ||
|
|
||
| """File writing tool for Agent Builder Assistant.""" | ||
|
|
There was a problem hiding this comment.
these are a lot of what looks like unrelated linter changes.
please remove them, and only submit the PR with the lines that actually matter to this set of changes.
| "summary": f"List {entity}", | ||
| "description": f"""Returns the list of {entity} data. If the page token was available in the response, let users know there are more records available. Ask if the user wants to fetch the next page of results. When passing filter use the | ||
| "description": ( | ||
| f"""Returns the list of {entity} data. If the page token was available in the response, let users know there are more records available. Ask if the user wants to fetch the next page of results. When passing filter use the |
There was a problem hiding this comment.
these are a lot of what looks like unrelated linter changes.
please remove them, and only submit the PR with the lines that actually matter to this set of changes.
Please ensure you have read the contribution guide before creating a pull request.
Link to Issue or Description of Change
1. Link to an existing issue (if applicable):
Problem:
For token streaming when adk agent is exposed with to_a2a
Solution:
Added streaming_mode in to_a2a to select streaming while exposing the agent