| |
@@ -0,0 +1,65 @@
|
| |
+ diff --git a/tests/test_queue.py b/tests/test_queue.py
|
| |
+ index 739d361..2f92f50 100644
|
| |
+ --- a/tests/test_queue.py
|
| |
+ +++ b/tests/test_queue.py
|
| |
+ @@ -6,6 +6,8 @@ import time
|
| |
+ import threading
|
| |
+ import asyncio
|
| |
+ from curio.traps import _read_wait
|
| |
+ +import pytest
|
| |
+ +import sys
|
| |
+
|
| |
+ def test_queue_simple(kernel):
|
| |
+ results = []
|
| |
+ @@ -523,6 +525,7 @@ def test_uqueue_asyncio_prod(kernel):
|
| |
+
|
| |
+ kernel.run(consumer())
|
| |
+
|
| |
+ +@pytest.mark.skipif(sys.version_info < (3, 7), reason="requires python 3.7 or higher for asyncio.run")
|
| |
+ def test_uqueue_asyncio_consumer(kernel):
|
| |
+ results = []
|
| |
+ async def consumer(queue):
|
| |
+ diff --git a/tests/test_sync.py b/tests/test_sync.py
|
| |
+ index b1316fb..7d4f5db 100644
|
| |
+ --- a/tests/test_sync.py
|
| |
+ +++ b/tests/test_sync.py
|
| |
+ @@ -5,6 +5,7 @@
|
| |
+ from collections import deque
|
| |
+ from curio import *
|
| |
+ import pytest
|
| |
+ +import sys
|
| |
+ import threading
|
| |
+ import time
|
| |
+ import asyncio
|
| |
+ @@ -768,6 +769,7 @@ class TestUniversalEvent:
|
| |
+ False
|
| |
+ ]
|
| |
+
|
| |
+ + @pytest.mark.skipif(sys.version_info < (3, 7), reason="requires python 3.7 or higher for asyncio.run")
|
| |
+ def test_uevent_get_asyncio_set(self, kernel):
|
| |
+ results = []
|
| |
+ async def event_setter(evt, seconds):
|
| |
+ @@ -806,6 +808,7 @@ class TestUniversalEvent:
|
| |
+ ]
|
| |
+
|
| |
+
|
| |
+ + @pytest.mark.skipif(sys.version_info < (3, 7), reason="requires python 3.7 or higher for asyncio.run")
|
| |
+ def test_uevent_get_asyncio_wait(self, kernel):
|
| |
+ results = []
|
| |
+ async def event_setter(evt, seconds):
|
| |
+ @@ -873,6 +876,7 @@ class TestResult:
|
| |
+
|
| |
+
|
| |
+ class TestUniversalResult:
|
| |
+ + @pytest.mark.skipif(sys.version_info < (3, 7), reason="requires python 3.7 or higher for asyncio.run")
|
| |
+ def test_universal_value(self, kernel):
|
| |
+
|
| |
+ def work(x, y, r):
|
| |
+ @@ -890,6 +894,7 @@ class TestUniversalResult:
|
| |
+ kernel.run(main, r2, r3)
|
| |
+ assert r3.unwrap() == 5
|
| |
+
|
| |
+ + @pytest.mark.skipif(sys.version_info < (3, 7), reason="requires python 3.7 or higher for asyncio.run")
|
| |
+ def test_universal_error(self, kernel):
|
| |
+
|
| |
+ def work(x, y, r):
|
| |
This is needed to port on EL8.
We need this package as a dependency for mailman3 packaging, so could you btw add EL8 build please?