We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0a7d10e commit 6031d25Copy full SHA for 6031d25
channels_redis/core.py
@@ -383,6 +383,7 @@ async def receive(self, channel):
383
except asyncio.CancelledError:
384
# Ensure all tasks are cancelled if we are cancelled.
385
# Also see: https://bugs.python.org/issue23859
386
+ del self.receive_buffer[channel]
387
for task in tasks:
388
if not task.cancel():
389
assert task.done()
@@ -433,6 +434,9 @@ async def receive(self, channel):
433
434
else:
435
self.receive_buffer[message_channel].put_nowait(message)
436
message = None
437
+ except:
438
439
+ raise
440
finally:
441
self.receive_lock.release()
442
0 commit comments