diff --git a/kfet/open/consumers.py b/kfet/open/consumers.py index 1b190212..4b21bef2 100644 --- a/kfet/open/consumers.py +++ b/kfet/open/consumers.py @@ -1,3 +1,5 @@ +from asgiref.sync import sync_to_async + from ..decorators import kfet_is_team from ..utils import DjangoJsonWebsocketConsumer, PermConsumerMixin from .open import kfet_open @@ -19,7 +21,7 @@ class OpenKfetConsumer(PermConsumerMixin, DjangoJsonWebsocketConsumer): """Send current status on connect.""" await super().connect() - group = "team" if kfet_is_team(self.user) else "base" + group = "team" if await sync_to_async(kfet_is_team)(self.user) else "base" await self.channel_layer.group_add(f"kfet.open.{group}", self.channel_name)