django/daphne
1
1
Fork 0
mirror of https://github.com/django/daphne.git synced 2025-04-21 01:02:06 +03:00
Code Issues Packages Projects Releases Wiki Activity

Wrap line properly

Browse Source
This commit is contained in:
Andrew Godwin 2016-04-05 22:29:00 -07:00
parent cd9c049296
commit 70637b7afe
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
channels/database_layer.py
View File

@ -60,7 +60,9 @@ class DatabaseChannelLayer(object):
while True:
try:
with transaction.atomic():
message = self.channel_model.objects.select_for_update().filter(channel__in=channels).order_by("id").first()
message = self.channel_model.objects.select_for_update().filter(
channel__in=channels
).order_by("id").first()
if message:
self.channel_model.objects.filter(pk=message.pk).delete()
return message.channel, self.deserialize(message.content)