Open martindurant opened 5 years ago
Errors like
____________________ ERROR at setup of test_identity[dask] _____________________
loop = <tornado.platform.asyncio.AsyncIOLoop object at 0x1724ad0860>
request = <SubRequest 'stream' for <Function 'test_identity[dask]'>>
client = <Client: scheduler='inproc://192.168.0.13/52337/1' processes=1 cores=8>
@pytest.fixture(params=["core", "dask"])
def stream(loop, request, client): # flake8: noqa
if request.param == "core":
return Stream()
else:
> return DaskStream()
rapidz/dataframe/tests/test_dataframes.py:43:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
rapidz/dask.py:43: in __init__
kwargs["loop"] = default_client().loop
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
c = None
def default_client(c=None):
""" Return a client if one has started """
c = c or _get_global_client()
if c:
return c
else:
> raise ValueError("No clients found\n"
"Start an client and point it to the scheduler address\n"
" from distributed import Client\n"
" client = Client('ip-addr-of-scheduler:8786')\n")
E ValueError: No clients found
E Start an client and point it to the scheduler address
E from distributed import Client
E client = Client('ip-addr-of-scheduler:8786')
../../anaconda/envs/py36/lib/python3.6/site-packages/distributed/client.py:3754: ValueError
Hmm, maybe those thest need to use the gen_cluster
syntax similar to rapidz/tests/test_dask.py
Following #23 :
15 failed, 1081 passed, 496 skipped, 23 xfailed, 112 xpassed, 105 warnings
and those are all, I think, dask cluster timeout failures. I haven't looked at what all those skips are missing in installation.
Hmm ok
Newly cloned, and running pytest results in
16 failed, 979 passed, 496 skipped, 23 xfailed, 112 xpassed, 115 warnings, 102 error
This is with pytest 3.10 and pytest-tornado installed. Full versions below. First, a sample failure:
Versions: