Tag: aioredis

asyncio python coroutine cancelled while task still pending reading from redis channel

I have multiple couroutines each of which waits for content in a queue to start processing. The content for the queues is populated by channel subscribers whose job is only to receive messages a push an item in the appropriate queue. After the data is consumed by one queue processor and new data is generated …

Asynchronous code failure when connecting to redis

aioredis async-await python python-asyncio redis

I created a small class to perform basic operations with redis, using aioredis. And a test handler to call the write/read operation for redis But get error I guess the problem could be that the asynchronous code has to be run through an event loop But I can’t understand how I can build this logic into m…