AttributeError("'AIOHTTPSession' object has no attribute 'close'")

[tomharvey]

This is being raised when I close my loop and is coming from:

and then I also get

'client_session': <aiohttp.client.ClientSession object at 0x154fd0940>, 'message': 'Unclosed client session'

hmmm ... shrodinger's close!

I can create this by calling

async with Producer(stream_name, processor=processor) as producer:

on a stream_name that doesn't exist.

I have:

aiobotocore==1.4.1
aiohttp==3.7.4.post0
async-kinesis==1.1.5

amongst many many other packages, but those seemed the relevant ones.

But, I suspect that this is a package version thing?