Fix: Use client.aio.aclose() instead of client.aclose() for async cleanup

Co-authored-by: owndev <69784886+owndev@users.noreply.github.com>

Author: Copilot

pipelines/google/google_gemini.py

@@ -1621,7 +1621,7 @@ async def _handle_streaming_response_with_cleanup(
         finally:
             # Ensure client is properly closed after streaming completes
             try:
-                await client.aclose()
+                await client.aio.aclose()
                 self.log.debug("Streaming client closed successfully")
             except Exception as close_error:
                 self.log.warning(f"Error closing streaming client: {close_error}")
@@ -2210,7 +2210,7 @@ async def get_response():
                 # Ensure client is properly closed for non-streaming responses
                 if not stream or supports_image_generation:
                     try:
-                        await client.aclose()
+                        await client.aio.aclose()
                         self.log.debug(
                             f"Request {request_id}: Client closed successfully"
                         )