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)