Fix syntax errors

Author: YeisonCardona

.github/workflows/python-package.yml

@@ -53,9 +53,9 @@ jobs:
 #    - name: Test remote
 #      run: |
 #        pytest test/test_remote.py -v
-#    - name: Test streamer
-#      run: |
-#        pytest test/test_streamer.py -v
-    - name: Test subscription
+    - name: Test streamer
       run: |
-        pytest test/test_subscription.py -v
+        pytest test/test_streamer.py -v
+#    - name: Test subscription
+#      run: |
+#        pytest test/test_subscription.py -v

test/test_streamer.py

@@ -9,6 +9,7 @@
 
 """
 
+import pytest
 import unittest
 import asyncio
 import os
@@ -26,10 +27,14 @@ class TestStreamer(unittest.IsolatedAsyncioTestCase):
     to ensure that messages are correctly streamed and received.
     """
 
-    #
-    def tearDown(self):
-        terminate_connections.main()
+    nodes = []
 
+    async def asyncTearDown(self):
+        for node in self.nodes:
+            print(f"Closing node {node.port}")
+            await node.stop()
+
+    @pytest.mark.asyncio
     async def test_stream(self) -> None:
         """
         Test the streaming functionality between a producer and a consumer.
@@ -62,6 +67,7 @@ async def test_stream(self) -> None:
 
         await run_transmission(producer, consumer, parent=self)
 
+    @pytest.mark.asyncio
     async def test_file_transfer(self) -> None:
         """
         Test the file transfer functionality between a producer and a consumer.
@@ -153,6 +159,7 @@ def new_file_event(**kwargs):
         await consumer.stop()
         await producer.stop()
 
+    @pytest.mark.asyncio
     async def test_file_dissable_transfer(self) -> None:
         """
         Test the file transfer functionality when the consumer has file transfer disabled.
@@ -213,6 +220,7 @@ async def test_file_dissable_transfer(self) -> None:
         await consumer.stop()
         await producer.stop()
 
+    @pytest.mark.asyncio
     async def test_stream_chain(self) -> None:
         """
         Test chaining of multiple ChaskiStreamer instances end-to-end.
@@ -312,6 +320,7 @@ async def test_stream_chain(self) -> None:
         await chain4.stop()
         await chain5.stop()
 
+    @pytest.mark.asyncio
     async def test_root_node(self) -> None:
         """
         Test chaining of multiple ChaskiStreamer instances end-to-end.