"Task was destroyed but it is pending" warning on exit about channels_redis HOT 13 CLOSED

I'm am also getting this error whenever the app is being redeployed. Is there a cleanup we should do before it or can we just safely ignore the error?

from channels_redis.

According to my Sentry events this "warning" is considered as an error.
level: error
logger: asyncio

from channels_redis.

In case it's relevant: aio-libs-abandoned/aioredis-py#154

from channels_redis.

This should be fixed by 6613baf - would appreciate others confirming this.

from channels_redis.

Looks like it's fixed. The exception is no longer being raised.

Does this commit also fix #71 ? I no longer get the warning mentioned in the linked issue.

from channels_redis.

Update : After downloading the latest commit, I'm having trouble sending group messages. They don't get sent at all now, but they were being sent properly before the commit.

from channels_redis.

Hmm, interesting, the tests for those are passing. Let me investigate interactively.

from channels_redis.

OK, group send/receive/add/discard all appears to work for me. Is there a particular situation you're seeing it not work in? I have tested in particular with https://github.com/andrewgodwin/channels-examples/tree/master/multichat

from channels_redis.

My mistake. After downloading the latest commit, I didn't restart all the processes running the application. Restarted and everything is working fine.

from channels_redis.

Ah, great. I'll consider this fixed then.

from channels_redis.

Hi, I am trying to use channels_redis(2.3.3) in an external program to communicate with django. I first tested in the python interpreter, send works fine, but I got the same error when I exited the interperter if receive function is used. Here is what I do in the interpreter:

>>> import channels_redis.core
>>> redis_server = channels_redis.core.RedisChannelLayer(hosts = [('127.0.0.1', 6379)])
>>> from asgiref.sync import async_to_sync
>>> async_to_sync(redis_server.send)('test', {'type': 'hello'})
>>> exit()
# Exited normally

>>> import channels_redis
>>> import channels_redis.core
>>> redis_server = channels_redis.core.RedisChannelLayer(hosts = [('127.0.0.1', 6379)])
>>> from asgiref.sync import async_to_sync
>>> async_to_sync(redis_server.send)('test', {'type': 'hello'})
>>> async_to_sync(redis_server.receive)('test')
{'type': 'hello'}
>>> exit()
Task was destroyed but it is pending!
task: <Task pending coro=<RedisChannelLayer._clean_receive_backup() ...

By the way, the communication between them works great, just getting the error message while exiting the program.

from channels_redis.

hello @andrewgodwin I'm facing the same problem with:
"aioredis": "1.3.1"
"asgiref": "3.3.1"
"channels": "2.4.0"
"channels-redis": "3.2.0"
maybe is related to channels version ? I had the same problem with async_to_sync.

from channels_redis.

Encountering this problem as well... Always receive this error after closing a connection in a Django Channels consumer

load-planner-api | Task was destroyed but it is pending!
load-planner-api | task: <Task pending name='Task-8' coro=<RedisConnection._read_data() running at /usr/local/lib/python3.8/site-packages/aioredis/connection.py:186> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x7fc0840a3580>()]> cb=[RedisConnection.__init__.<locals>.<lambda>() at /usr/local/lib/python3.8/site-packages/aioredis/connection.py:168]>

from channels_redis.