Unknown AIOHttpConnection type errors about aioelasticsearch HOT 5 OPEN

What exact Python version You are using?

from aioelasticsearch.

Can You provide an example which fails this way?

from aioelasticsearch.

I am using Python 3.6.2. Example is a bit hard for me to create as it generally happens on some background tasks that I am running. And 99% of those tasks run successfully, but it fails every now and then. The actual code is something very simple:

    await es.index(
        index=es_index_name('player_stats'),
        doc_type="player_stats",
        body=body,
        id=body.get('id'),
    )

where body is just a dict.

My main question is: What does this class do exactly? Does it have to do with available connection pool / timeouts for ES?

If it’s related to timeout, I will try to see if I should add nodes. But I have already seen previously that when it timeouts, it throws the timeout exception. I tried reading through the source but I am not proficient enough to debug this.

from aioelasticsearch.

I found an issue, seems queue.PriorityQueue and asyncio.PriorityQueue works little bit different , which was ported from original driver. Ill try to provide a fix for that this weekend

from aioelasticsearch.

Sweet—thank you!

from aioelasticsearch.