|
5 | 5 | import http.server |
6 | 6 | from io import BytesIO |
7 | 7 | import multiprocessing |
| 8 | +import os |
8 | 9 | import socket |
9 | 10 | import time |
10 | 11 | import urllib.error |
|
16 | 17 | import pandas as pd |
17 | 18 | import pandas._testing as tm |
18 | 19 |
|
| 20 | +pytestmark = pytest.mark.skipif( |
| 21 | + os.environ.get("PANDAS_CI", "0") == "1", |
| 22 | + reason="This test can hang in our CI min_versions build " |
| 23 | + "and leads to '##[error]The runner has " |
| 24 | + "received a shutdown signal...' in GHA. GH 45651", |
| 25 | +) |
| 26 | + |
19 | 27 |
|
20 | 28 | class BaseUserAgentResponder(http.server.BaseHTTPRequestHandler): |
21 | 29 | """ |
@@ -242,7 +250,9 @@ def responder(request): |
242 | 250 | pd.read_parquet, |
243 | 251 | "fastparquet", |
244 | 252 | # TODO(ArrayManager) fastparquet |
245 | | - marks=td.skip_array_manager_not_yet_implemented, |
| 253 | + marks=[ |
| 254 | + td.skip_array_manager_not_yet_implemented, |
| 255 | + ], |
246 | 256 | ), |
247 | 257 | (PickleUserAgentResponder, pd.read_pickle, None), |
248 | 258 | (StataUserAgentResponder, pd.read_stata, None), |
@@ -277,7 +287,9 @@ def test_server_and_default_headers(responder, read_method, parquet_engine): |
277 | 287 | pd.read_parquet, |
278 | 288 | "fastparquet", |
279 | 289 | # TODO(ArrayManager) fastparquet |
280 | | - marks=td.skip_array_manager_not_yet_implemented, |
| 290 | + marks=[ |
| 291 | + td.skip_array_manager_not_yet_implemented, |
| 292 | + ], |
281 | 293 | ), |
282 | 294 | (PickleUserAgentResponder, pd.read_pickle, None), |
283 | 295 | (StataUserAgentResponder, pd.read_stata, None), |
|
0 commit comments