From 260a819eb3398f71c4e15bbe7e590ccd0c1ad161 Mon Sep 17 00:00:00 2001 From: Tom Hubrecht Date: Thu, 30 Jun 2022 09:39:05 +0200 Subject: [PATCH] Try to flush old messages in tests --- kfet/open/tests.py | 4 +++- kfet/tests/test_views.py | 4 ++++ 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/kfet/open/tests.py b/kfet/open/tests.py index 9eb07697..a30ecb99 100644 --- a/kfet/open/tests.py +++ b/kfet/open/tests.py @@ -283,8 +283,10 @@ class OpenKfetScenarioTest(TestCase): cls.r_c.login(username="team", password="team") def setUp(self): - # Create a channel to listen to KPsul's messages + # Create channels to listen to messages channel_layer = get_channel_layer() + async_to_sync(channel_layer.flush)() + self.channel = async_to_sync(channel_layer.new_channel)() self.team_channel = async_to_sync(channel_layer.new_channel)() diff --git a/kfet/tests/test_views.py b/kfet/tests/test_views.py index 39ec0aa7..153bb1b5 100644 --- a/kfet/tests/test_views.py +++ b/kfet/tests/test_views.py @@ -1812,6 +1812,7 @@ class KPsulPerformOperationsViewTests(ViewTestCaseMixin, TestCase): # Create a channel to listen to KPsul's messages channel_layer = get_channel_layer() + async_to_sync(channel_layer.flush)() self.channel = async_to_sync(channel_layer.new_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 channel_layer = get_channel_layer() + + # Flush old messages + async_to_sync(channel_layer.flush)() self.channel = async_to_sync(channel_layer.new_channel)() async_to_sync(channel_layer.group_add)("kfet.kpsul", self.channel)