fix(google_ai): close aiohttp session to prevent ResourceWarning

[raymondWai]

Related Issues

• fixes Fix Uncloused Client Error trigger when use GoogleGenAIChatGenerator in a AsyncPipeline #2628

Proposed Changes:

When I try to use GoogleGenAIChatGenerator in a AsyncPipeline, It always show Unclosed client session error.

What I do to fix it is adding self._client.aio.aclose() to the finally clause to run_async function

How did you test it?

Run pytest integrations/google_genai/tests/

Checklist

• I have read the contributors guidelines and the code of conduct
• I have updated the related issue with new insights and changes
• I added unit tests and updated the docstrings
• I've used one of the conventional commit types for my PR title: fix:, feat:, build:, chore:, ci:, docs:, style:, refactor:, perf:, test:.

[CLAassistant]

All committers have signed the CLA.

[vblagoje]

Thanks for the contrib but I don't think this is the right approach. The fix should close the session when the component is destroyed, not after each run_async call. The _client is stored as self._client (instance variable) and not created fresh each time.

[raymondWai]

Just moved the close method call to destructor and exit

[anakin87]

Sorry for the delay.

Could you please rebase your branch or merge main? There are some conflicts.