DGNum/gestioCOF
16
2
Fork 2
Code Issues 79 Pull requests 21 Projects Releases 12 Packages Wiki Activity

Thubrecht/daphne #815

Merged
thubrecht merged 39 commits from thubrecht/daphne into master 2024-07-30 18:40:56 +02:00
Conversation 32 Commits 39 Files changed 89 +7 -1
2 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 7d8926e459 - Show all commits

4
kfet/open/tests.py
View file

@ -283,8 +283,10 @@ class OpenKfetScenarioTest(TestCase):
cls.r_c.login(username="team", password="team") cls.r_c.login(username="team", password="team")
def setUp(self): def setUp(self):
# Create a channel to listen to KPsul's messages # Create channels to listen to messages
channel_layer = get_channel_layer() channel_layer = get_channel_layer()
async_to_sync(channel_layer.flush)()
self.channel = async_to_sync(channel_layer.new_channel)() self.channel = async_to_sync(channel_layer.new_channel)()
self.team_channel = async_to_sync(channel_layer.new_channel)() self.team_channel = async_to_sync(channel_layer.new_channel)()

4
kfet/tests/test_views.py
View file

@ -1812,6 +1812,7 @@ class KPsulPerformOperationsViewTests(ViewTestCaseMixin, TestCase):
# Create a channel to listen to KPsul's messages # Create a channel to listen to KPsul's messages
channel_layer = get_channel_layer() channel_layer = get_channel_layer()
async_to_sync(channel_layer.flush)()
self.channel = async_to_sync(channel_layer.new_channel)() self.channel = async_to_sync(channel_layer.new_channel)()
async_to_sync(channel_layer.group_add)("kfet.kpsul", self.channel) async_to_sync(channel_layer.group_add)("kfet.kpsul", self.channel)
@ -3240,6 +3241,9 @@ class KPsulCancelOperationsViewTests(ViewTestCaseMixin, TestCase):
# Create a channel to listen to KPsul's messages # Create a channel to listen to KPsul's messages
channel_layer = get_channel_layer() channel_layer = get_channel_layer()
# Flush old messages
async_to_sync(channel_layer.flush)()
self.channel = async_to_sync(channel_layer.new_channel)() self.channel = async_to_sync(channel_layer.new_channel)()
async_to_sync(channel_layer.group_add)("kfet.kpsul", self.channel) async_to_sync(channel_layer.group_add)("kfet.kpsul", self.channel)