Асинхронное обновление модели Django не выполняется

Обновление SQL, похоже, не выполняется, и ошибок тоже не возникает. Ниже приведена упрощенная версия моего кода. Для контекста, поле "choice" в модели является булевым полем со значением по умолчанию False, и пользователь может (в идеале) изменить его, отправив пакет JSON с событием "CHOICE" и сообщением "Yes"

consumers.py

import json
from channels.generic.websocket import AsyncJsonWebsocketConsumer
from asgiref.sync import sync_to_async
from .models import Room

class Consumer(AsyncJsonWebsocketConsumer):
    async def connect(self):
        self.room_code = self.scope['url_route']['kwargs']['room_code']
        #Websockets connection code
    async def disconnect(self):
        #Websockets disconnect code
    async def receive(self, text_data):
        response = json.loads(text_data)
        event = response.get("event", None)
        message = response.get("message", None)
        if event == "CHOICE":
            room_set = await sync_to_async(Room.objects.filter)(room_code=self.room_code)
            room = await sync_to_async(room_set.first)()
            if (not room.choice) and message["choice"] == 'Yes':
                sync_to_async(room_set.update)(choice=True) #line seems to not be working
            elif room.choice and message["choice"] == 'No':
                sync_to_async(room_set.update)(choice=False)
            #code to send message to group over Websockets
        #code regarding other events
    async def send_message(self, res):
        #Websockets send message code

Я постарался включить сюда только соответствующий код, но если потребуется больше, пожалуйста, дайте мне знать. Заранее спасибо!

Я решил эту проблему, добавив await перед строками sync_to_async(room.update)(choice=True). Похоже, что без await он переходит к следующей строке кода до завершения обновления SQL, в результате чего обновление не происходит.

Вернуться на верх