1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
From: Nilesh Patra <npatra974@gmail.com>
Date: Fri, 17 Feb 2023 00:17:13 +0530
Subject: Disable tests trying to connect to TCP/http ports
Last-Changed: Tue July 16, 2020
Forwarded: Not-Needed
---
streamz/tests/test_sources.py | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/streamz/tests/test_sources.py b/streamz/tests/test_sources.py
index 8210a8d..36c6381 100644
--- a/streamz/tests/test_sources.py
+++ b/streamz/tests/test_sources.py
@@ -17,7 +17,7 @@ def test_periodic():
wait_for(lambda: len(l) > 1, 0.3, period=0.01)
assert all(l)
-
+@pytest.mark.xfail(reason="Tries connecting to port")
@flaky(max_runs=3, min_passes=1)
def test_tcp():
port = 9876
@@ -46,7 +46,7 @@ def test_tcp():
sock.close()
sock2.close()
-
+@pytest.mark.xfail(reason="Tries connecting to port")
@flaky(max_runs=3, min_passes=1)
@gen_test(timeout=60)
def test_tcp_async():
@@ -77,6 +77,7 @@ def test_tcp_async():
sock2.close()
+@pytest.mark.xfail(reason="Tries connecting to port")
def test_http():
requests = pytest.importorskip('requests')
port = 9875
@@ -99,6 +100,7 @@ def test_http():
requests.post('http://localhost:%i/other' % port, data=b'data2')
+@pytest.mark.xfail(reason="Tries connecting to port")
@gen_test(timeout=60)
def test_process():
cmd = ["python", "-c", "for i in range(4): print(i, end='')"]
@@ -115,6 +117,7 @@ def test_process():
s.stop()
+@pytest.mark.xfail(reason="Tries connecting to port")
@gen_test(timeout=60)
def test_process_str():
cmd = 'python -c "for i in range(4): print(i)"'
|
