Worked on the google/adk-python repository to deliver a real-time performance enhancement for the VertexAiRagRetrieval component. Refactored the run_async method to defer blocking gRPC calls to a worker thread using Python’s asyncio.to_thread, addressing event-loop stalls that previously caused latency issues in streaming scenarios. This approach improved audio and video synchronization and enhanced the reliability of real-time streaming by eliminating delays in bidirectional streaming modes. The implementation was aligned with existing ADK threading patterns used across other services, such as GCS and BigQuery tools, demonstrating proficiency in Python, asynchronous programming, and gRPC to standardize asynchronous workflows.