Tests fail (unnecessarily) when networking is unavailable

Open

#4,005 opened on Aug 1, 2020 5 comments 0 reactions 0 assignees View on GitHub

Dominant language: Python
Stars: 1.7k
Forks: 778
Avg merge: 2h 50m
Merged PRs (30d): 3

Description

**What happened**:

Tests fail immediately when the system does not have Internet access:

```
=============================================================== test session starts ===============================================================
platform linux -- Python 3.6.11, pytest-6.0.1, py-1.9.0, pluggy-0.13.1 -- /usr/bin/python3.6
cachedir: .pytest_cache
hypothesis profile 'default' -> database=DirectoryBasedExampleDatabase('/tmp/portage/dev-python/distributed-2.22.0/work/distributed-2.22.0/.hypothesis/examples')
rootdir: /tmp/portage/dev-python/distributed-2.22.0/work/distributed-2.22.0, configfile: setup.cfg
plugins: mock-3.2.0, pyfakefs-4.1.0, shutil-1.7.0, virtualenv-1.7.0, timeout-1.4.1, freezegun-0.4.2, localserver-0.5.0, forked-1.3.0, xdist-1.34.0, asyncio-0.14.0, hypothesis-5.23.7
collecting ... collected 57 items / 1 error / 56 selected

===================================================================== ERRORS ======================================================================
______________________________________________ ERROR collecting distributed/comm/tests/test_comms.py ______________________________________________
/usr/lib64/python3.6/site-packages/toolz/functoolz.py:456: in memof
return cache[k]
E KeyError: ('2001:4860:4860::8888', 80)
args = ('2001:4860:4860::8888', 80)
cache = {('8.8.8.8', 80): '127.0.0.1'}
func =
k = ('2001:4860:4860::8888', 80)
key = .key at 0x7f5069419d08>
kwargs = {'family': }

During handling of the above exception, another exception occurred:
distributed/utils.py:136: in _get_ip
sock.connect((host, port))
E OSError: [Errno 101] Network is unreachable
family =
host = '2001:4860:4860::8888'
port = 80
sock =

During handling of the above exception, another exception occurred:
distributed/comm/tests/test_comms.py:48: in
EXTERNAL_IP6 = get_ipv6()
CommClosedError =
EXTERNAL_IP4 = '127.0.0.1'
Future =
Serialized =
__builtins__ =
__cached__ = '/tmp/portage/dev-python/distributed-2.22.0/work/distributed-2.22.0/distributed/comm/tests/__pycache__/test_comms.cpython-36.pyc'
__doc__ = None
__file__ = '/tmp/portage/dev-python/distributed-2.22.0/work/distributed-2.22.0/distributed/comm/tests/test_comms.py'
__loader__ = <_pytest.assertion.rewrite.AssertionRewritingHook object at 0x7f506a420320>
__name__ = 'distributed.comm.tests.test_comms'
__package__ = 'distributed.comm.tests'
__spec__ = ModuleSpec(name='distributed.comm.tests.test_comms', loader=<_pytest.assertion.rewrite.AssertionRewritingHook object at 0x7f506a420320>, origin='/tmp/portage/dev-python/distributed-2.22.0/work/distributed-2.22.0/distributed/comm/tests/test_comms.py')
asyncio =
backends = {'inproc': ,
'tcp': ,
'tls': ,
'ucx': }
connect =
deserialize =
distributed =
get_address_host =
get_backend =
get_cert =
get_client_ssl_context =
get_ip =
get_ipv6 =
get_local_address_for =
get_server_ssl_context =
has_ipv6 = .memof at 0x7f5063913598>
inproc =
ioloop =
listen =
loop =
os =
parse_address =
parse_host_port =
partial =
pkg_resources =
pytest =
requires_ipv6 =
resolve_address =
serialize =
sys =
tcp =
threading =
time =
to_serialize =
types =
unparse_host_port =
warnings =
distributed/utils.py:167: in get_ipv6
return _get_ip(host, port, family=socket.AF_INET6)
host = '2001:4860:4860::8888'
port = 80
/usr/lib64/python3.6/site-packages/toolz/functoolz.py:460: in memof
cache[k] = result = func(*args, **kwargs)
args = ('2001:4860:4860::8888', 80)
cache = {('8.8.8.8', 80): '127.0.0.1'}
func =
k = ('2001:4860:4860::8888', 80)
key = .key at 0x7f5069419d08>
kwargs = {'family': }
distributed/utils.py:146: in _get_ip
socket.gethostname(), port, family, socket.SOCK_DGRAM, socket.IPPROTO_UDP
family =
host = '2001:4860:4860::8888'
port = 80
sock =
/usr/lib64/python3.6/socket.py:745: in getaddrinfo
for res in _socket.getaddrinfo(host, port, family, type, proto, flags):
E socket.gaierror: [Errno -5] No address associated with hostname
addrlist = []
family =
flags = 0
host = 'localhost'
port = 80
proto = 17
type =
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! stopping after 1 failures !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
================================================================ 1 error in 1.99s =================================================================
```

**What you expected to happen**:

I expected at least subset of tests to be usable in network-constrained environments.

**Anything else we need to know?**:

It seems that replacing `has_ipv6()` with explicit `False` helps it get past initial error. However, the majority of tests still fail because of network failures, e.g.:

distributed/cli/tests/test_dask_scheduler.py::test_defaults FAILED [ 0%]

==================================================================== FAILURES =====================================================================
__________________________________________________________________ test_defaults __________________________________________________________________

args = ('2001:4860:4860::8888', 80), kwargs = {'family': }, k = ('2001:4860:4860::8888', 80)

def memof(*args, **kwargs):
k = key(args, kwargs)
try:
> return cache[k]
E KeyError: ('2001:4860:4860::8888', 80)

args = ('2001:4860:4860::8888', 80)
cache = {('8.8.8.8', 80): '127.0.0.1'}
func =
k = ('2001:4860:4860::8888', 80)
key = .key at 0x7f0b63eddd08>
kwargs = {'family': }

/usr/lib64/python3.6/site-packages/toolz/functoolz.py:456: KeyError

During handling of the above exception, another exception occurred:

host = '2001:4860:4860::8888', port = 80, family =

@toolz.memoize
def _get_ip(host, port, family):
# By using a UDP socket, we don't actually try to connect but
# simply select the local address through which *host* is reachable.
sock = socket.socket(family, socket.SOCK_DGRAM)
try:
> sock.connect((host, port))
E OSError: [Errno 101] Network is unreachable

family =
host = '2001:4860:4860::8888'
port = 80
sock =

distributed/utils.py:136: OSError

During handling of the above exception, another exception occurred:

loop =

def test_defaults(loop):
with popen(["dask-scheduler", "--no-dashboard"]) as proc:

async def f():
# Default behaviour is to listen on all addresses
await assert_can_connect_from_everywhere_4_6(8786, timeout=5.0)

with Client("127.0.0.1:%d" % Scheduler.default_port, loop=loop) as c:
> c.sync(f)

c =
f = .f at 0x7f0b538a8d08>
loop =
proc =

distributed/cli/tests/test_dask_scheduler.py:36:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
distributed/client.py:833: in sync
self.loop, func, *args, callback_timeout=callback_timeout, **kwargs
args = ()
asynchronous = None
callback_timeout = None
func = .f at 0x7f0b538a8d08>
kwargs = {}
self =
distributed/utils.py:339: in sync
raise exc.with_traceback(tb)
args = ()
callback_timeout = None
e =
error = [(,
gaierror(-5, 'No address associated with hostname'),
)]
exc = gaierror(-5, 'No address associated with hostname')
f = .f at 0x7f0b53804158>
func = .f at 0x7f0b538a8d08>
kwargs = {}
loop =
main_tid = 139686948337472
result = [None]
tb =
typ =
distributed/utils.py:323: in f
result[0] = yield future
args = ()
callback_timeout = None
e =
error = [(,
gaierror(-5, 'No address associated with hostname'),
)]
func = .f at 0x7f0b538a8d08>
future =
kwargs = {}
main_tid = 139686948337472
result = [None]
/usr/lib64/python3.6/site-packages/tornado/gen.py:735: in run
value = future.result()
exc_info = None
future = None
self =
distributed/cli/tests/test_dask_scheduler.py:33: in f
await assert_can_connect_from_everywhere_4_6(8786, timeout=5.0)
distributed/utils_test.py:1131: in assert_can_connect_from_everywhere_4_6
assert_can_connect("%s://[%s]:%d" % (protocol, get_ipv6(), port), **kwargs),
futures = [,
]
kwargs = {'timeout': 5.0}
port = 8786
protocol = 'tcp'
distributed/utils.py:167: in get_ipv6
return _get_ip(host, port, family=socket.AF_INET6)
host = '2001:4860:4860::8888'
port = 80
/usr/lib64/python3.6/site-packages/toolz/functoolz.py:460: in memof
cache[k] = result = func(*args, **kwargs)
args = ('2001:4860:4860::8888', 80)
cache = {('8.8.8.8', 80): '127.0.0.1'}
func =
k = ('2001:4860:4860::8888', 80)
key = .key at 0x7f0b63eddd08>
kwargs = {'family': }
distributed/utils.py:146: in _get_ip
socket.gethostname(), port, family, socket.SOCK_DGRAM, socket.IPPROTO_UDP
family =
host = '2001:4860:4860::8888'
port = 80
sock =
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

host = 'localhost', port = 80, family = , type = , proto = 17, flags = 0

def getaddrinfo(host, port, family=0, type=0, proto=0, flags=0):
"""Resolve host and port into list of address info entries.

Translate the host/port argument into a sequence of 5-tuples that contain
all the necessary arguments for creating a socket connected to that service.
host is a domain name, a string representation of an IPv4/v6 address or
None. port is a string service name such as 'http', a numeric port number or
None. By passing None as the value of host and port, you can pass NULL to
the underlying C API.

The family, type and proto arguments can be optionally specified in order to
narrow the list of addresses returned. Passing zero as a value for each of
these arguments selects the full range of results.
"""
# We override this function since we want to translate the numeric family
# and socket type values to enum constants.
addrlist = []
> for res in _socket.getaddrinfo(host, port, family, type, proto, flags):
E socket.gaierror: [Errno -5] No address associated with hostname

addrlist = []
family =
flags = 0
host = 'localhost'
port = 80
proto = 17
type =

/usr/lib64/python3.6/socket.py:745: gaierror
-------------------------------------------------------------- Captured stdout call ---------------------------------------------------------------

Print from stderr
d
=================

distributed.scheduler - INFO - -----------------------------------------------
distributed.http.proxy - INFO - To route to workers diagnostics web server please install jupyter-server-proxy: python -m pip install jupyter-server-proxy
distributed.scheduler - INFO - -----------------------------------------------
distributed.scheduler - INFO - Clear task state
distributed.scheduler - INFO - Scheduler at: tcp://127.0.0.1:8786
distributed.scheduler - INFO - dashboard at: :8787
distributed.scheduler - INFO - Receive client connection: Client-410542b8-d3c2-11ea-8050-b7f84a3806c1
distributed.core - INFO - Starting established connection
distributed.scheduler - INFO - Remove client Client-410542b8-d3c2-11ea-8050-b7f84a3806c1
distributed.scheduler - INFO - Remove client Client-410542b8-d3c2-11ea-8050-b7f84a3806c1
distributed.scheduler - INFO - Close client connection: Client-410542b8-d3c2-11ea-8050-b7f84a3806c1
distributed.scheduler - INFO - End scheduler at 'tcp://127.0.0.1:8786'
Traceback (most recent call last):
File "/tmp/portage/dev-python/distributed-2.22.0/work/distributed-2.22.0-python3_6/test/scripts/dask-scheduler", line 11, in
load_entry_point('distributed==2.22.0', 'console_scripts', 'dask-scheduler')()
File "/tmp/portage/dev-python/distributed-2.22.0/work/distributed-2.22.0-python3_6/lib/distributed/cli/dask_scheduler.py", line 226, in go
main()
File "/usr/lib64/python3.6/site-packages/click/core.py", line 829, in __call__
return self.main(*args, **kwargs)
File "/usr/lib64/python3.6/site-packages/click/core.py", line 782, in main
rv = self.invoke(ctx)
File "/usr/lib64/python3.6/site-packages/click/core.py", line 1066, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "/usr/lib64/python3.6/site-packages/click/core.py", line 610, in invoke
return callback(*args, **kwargs)
File "/tmp/portage/dev-python/distributed-2.22.0/work/distributed-2.22.0-python3_6/lib/distributed/cli/dask_scheduler.py", line 217, in main
loop.run_sync(run)
File "/usr/lib64/python3.6/site-packages/tornado/ioloop.py", line 531, in run_sync
raise TimeoutError("Operation timed out after %s seconds" % timeout)
tornado.util.TimeoutError: Operation timed out after None seconds

Print from stdout
=================

================================================================ warnings summary =================================================================
distributed/cli/tests/test_dask_scheduler.py::test_defaults
/tmp/portage/dev-python/distributed-2.22.0/work/distributed-2.22.0/distributed/utils.py:143: RuntimeWarning: Couldn't detect a suitable IP address for reaching '2001:4860:4860::8888', defaulting to hostname: [Errno 101] Network is unreachable
RuntimeWarning,

Even if I skip tests that fail immediately, a lot of tests error out during teardown:

distributed/cli/tests/test_dask_scheduler.py::test_no_dashboard SKIPPED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_dashboard SKIPPED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_dashboard_non_standard_ports SKIPPED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_dashboard_whitelist SKIPPED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_interface PASSED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_pid_file SKIPPED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_scheduler_port_zero PASSED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_dashboard_port_zero SKIPPED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_preload_file PASSED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_preload_module PASSED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_preload_remote_module PASSED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_preload_command PASSED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_preload_command_default PASSED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_version_option PASSED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_idle_timeout PASSED [ 0%]
distributed/cli/tests/test_dask_scheduler.py::test_multiple_workers PASSED [ 0%]
distributed/cli/tests/test_dask_spec.py::test_text PASSED [ 1%]
distributed/cli/tests/test_dask_spec.py::test_file PASSED [ 1%]
distributed/cli/tests/test_dask_spec.py::test_errors PASSED [ 1%]
distributed/cli/tests/test_dask_ssh.py::test_version_option PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_nanny_worker_ports PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_nanny_worker_port_range PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_nanny_worker_port_range_too_many_workers_raises PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_memory_limit PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_no_nanny PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_no_reconnect[--nanny] PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_no_reconnect[--no-nanny] PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_resources PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_local_directory[--nanny] PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_local_directory[--no-nanny] PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_scheduler_file[--nanny] PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_scheduler_file[--no-nanny] PASSED [ 1%]
distributed/cli/tests/test_dask_worker.py::test_scheduler_address_env PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_nprocs_requires_nanny PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_nprocs_expands_name PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_contact_listen_address[tcp://0.0.0.0:39837---nanny] PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_contact_listen_address[tcp://0.0.0.0:39837---no-nanny] PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_contact_listen_address[tcp://127.0.0.2:39837---nanny] PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_contact_listen_address[tcp://127.0.0.2:39837---no-nanny] PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_respect_host_listen_address[127.0.0.2---nanny] PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_respect_host_listen_address[127.0.0.2---no-nanny] PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_respect_host_listen_address[0.0.0.0---nanny] PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_respect_host_listen_address[0.0.0.0---no-nanny] PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_dashboard_non_standard_ports SKIPPED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_version_option PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_worker_timeout[True] PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_worker_timeout[False] PASSED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_bokeh_deprecation SKIPPED [ 2%]
distributed/cli/tests/test_dask_worker.py::test_integer_names PASSED [ 3%]
distributed/cli/tests/test_dask_worker.py::test_integer_names ERROR [ 3%]

@pytest.fixture
def cleanup():
with clean():
> yield

distributed/utils_test.py:1541:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/lib64/python3.6/contextlib.py:88: in __exit__
next(self.gen)
self =
traceback = None
type = None
value = None
distributed/utils_test.py:1535: in clean
del thread_state.on_event_loop_thread
instances = True
level = 0
loop =
name = 'distributed.utils_test'
null = .null at 0x7fa3df7e9bf8>
processes = True
threads = True
timeout = 1
/usr/lib64/python3.6/contextlib.py:88: in __exit__
next(self.gen)
self =
traceback = None
type = None
value = None
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

@contextmanager
def check_thread_leak():
active_threads_start = set(threading._active)

yield

start = time()
while True:
bad = [
t
for t, v in threading._active.items()
if t not in active_threads_start
and "Threaded" not in v.name
and "watch message" not in v.name
and "TCP-Executor" not in v.name
]
if not bad:
break
else:
sleep(0.01)
if time() > start + 5:
from distributed import profile

tid = bad[0]
thread = threading._active[tid]
call_stacks = profile.call_stack(sys._current_frames()[tid])
> assert False, (thread, call_stacks)
E AssertionError: (, [' File "/usr/lib64/python3.6/threading.py", line 884, in _bootst...-python/distributed-2.22.0/work/distributed-2.22.0/distributed/profile.py", line 269, in _watch
E \tsleep(interval)
E '])
E assert False

active_threads_start = {140341765310208,
140341773702912,
140341782095616,
140341977769728,
140342131173184}
bad = [140341756917504]
call_stacks = [' File "/usr/lib64/python3.6/threading.py", line 884, in _bootstrap\n'
'\tself._bootstrap_inner()\n',
' File "/usr/lib64/python3.6/threading.py", line 916, in _bootstrap_inner\n'
'\tself.run()\n',
' File "/usr/lib64/python3.6/threading.py", line 864, in run\n'
'\tself._target(*self._args, **self._kwargs)\n',
' File '
'"/tmp/portage/dev-python/distributed-2.22.0/work/distributed-2.22.0/distributed/profile.py", '
'line 269, in _watch\n'
'\tsleep(interval)\n']
profile =
start = 1596264403.1102982
thread =
tid = 140341756917504

distributed/utils_test.py:1435: AssertionError
-------------------------------------------------------------- Captured stderr call ---------------------------------------------------------------
distributed.scheduler - INFO - Clear task state
distributed.scheduler - INFO - Scheduler at: tcp://127.0.0.1:42373
distributed.scheduler - INFO - dashboard at: :8787
distributed.scheduler - INFO - Register worker
distributed.scheduler - INFO - Starting worker compute stream, tcp://127.0.0.1:42145
distributed.core - INFO - Starting established connection
distributed.scheduler - INFO - Scheduler closing...
distributed.scheduler - INFO - Scheduler closing all comms
distributed.scheduler - INFO - Remove worker
distributed.core - INFO - Removing comms to tcp://127.0.0.1:42145
distributed.scheduler - INFO - Lost all workers
================================================================ warnings summary =================================================================
distributed/cli/tests/test_dask_worker.py::test_worker_timeout[True]
/tmp/portage/dev-python/distributed-2.22.0/work/distributed-2.22.0/distributed/utils.py:143: RuntimeWarning: Couldn't detect a suitable IP address for reaching '192.168.1.100', defaulting to hostname: [Errno 101] Network is unreachable
RuntimeWarning,

-- Docs: https://docs.pytest.org/en/stable/warnings.html
============================================================== slowest 10 durations ===============================================================
5.32s call distributed/cli/tests/test_dask_worker.py::test_no_reconnect[--nanny]
5.00s teardown distributed/cli/tests/test_dask_worker.py::test_integer_names
4.56s call distributed/cli/tests/test_dask_worker.py::test_nprocs_expands_name
3.93s call distributed/cli/tests/test_dask_worker.py::test_nanny_worker_port_range
3.85s call distributed/cli/tests/test_dask_worker.py::test_respect_host_listen_address[127.0.0.2---nanny]
3.85s call distributed/cli/tests/test_dask_worker.py::test_no_reconnect[--no-nanny]
3.85s call distributed/cli/tests/test_dask_worker.py::test_contact_listen_address[tcp://127.0.0.2:39837---nanny]
3.80s call distributed/cli/tests/test_dask_worker.py::test_respect_host_listen_address[0.0.0.0---nanny]
3.79s call distributed/cli/tests/test_dask_worker.py::test_scheduler_file[--nanny]
3.77s call distributed/cli/tests/test_dask_worker.py::test_memory_limit
============================================================= short test summary info =============================================================
SKIPPED [1] distributed/comm/tests/test_ucx.py:4: could not import 'ucp': No module named 'ucp'
SKIPPED [1] distributed/comm/tests/test_ucx_config.py:16: could not import 'ucp': No module named 'ucp'
SKIPPED [1] distributed/dashboard/tests/test_components.py:5: could not import 'bokeh': No module named 'bokeh'
SKIPPED [1] distributed/dashboard/tests/test_scheduler_bokeh.py:10: could not import 'bokeh': No module named 'bokeh'
SKIPPED [1] distributed/dashboard/tests/test_worker_bokeh.py:8: could not import 'bokeh': No module named 'bokeh'
SKIPPED [1] distributed/deploy/tests/test_ssh.py:3: could not import 'asyncssh': No module named 'asyncssh'
SKIPPED [1] distributed/diagnostics/tests/test_progress_stream.py:3: could not import 'bokeh': No module named 'bokeh'
SKIPPED [1] distributed/diagnostics/tests/test_widgets.py:3: could not import 'ipywidgets': No module named 'ipywidgets'
SKIPPED [1] distributed/http/scheduler/tests/test_scheduler_http.py:6: could not import 'bokeh': No module named 'bokeh'
SKIPPED [1] distributed/protocol/tests/test_arrow.py:4: could not import 'pyarrow': No module named 'pyarrow'
SKIPPED [1] distributed/protocol/tests/test_cupy.py:6: could not import 'cupy': No module named 'cupy'
SKIPPED [1] distributed/protocol/tests/test_h5py.py:6: could not import 'h5py': No module named 'h5py'
SKIPPED [1] distributed/protocol/tests/test_keras.py:5: could not import 'keras': No module named 'keras'
SKIPPED [1] distributed/protocol/tests/test_netcdf4.py:3: could not import 'netCDF4': No module named 'netCDF4'
SKIPPED [1] distributed/protocol/tests/test_numba.py:5: could not import 'numba.cuda': No module named 'numba'
SKIPPED [1] distributed/protocol/tests/test_rmm.py:5: could not import 'numba.cuda': No module named 'numba'
SKIPPED [1] distributed/protocol/tests/test_sklearn.py:3: could not import 'sklearn': No module named 'sklearn'
SKIPPED [1] distributed/protocol/tests/test_sparse.py:5: could not import 'sparse': No module named 'sparse'
SKIPPED [1] distributed/protocol/tests/test_torch.py:5: could not import 'torch': No module named 'torch'
SKIPPED [1] distributed/tests/test_gpu_metrics.py:4: could not import 'pynvml': No module named 'pynvml'
SKIPPED [1] distributed/cli/tests/test_dask_scheduler.py:58: could not import 'bokeh': No module named 'bokeh'
SKIPPED [1] distributed/cli/tests/test_dask_scheduler.py:66: could not import 'bokeh': No module named 'bokeh'
SKIPPED [1] distributed/cli/tests/test_dask_scheduler.py:100: could not import 'bokeh': No module named 'bokeh'
SKIPPED [1] distributed/cli/tests/test_dask_scheduler.py:125: could not import 'bokeh': No module named 'bokeh'
SKIPPED [1] distributed/cli/tests/test_dask_scheduler.py:188: Intermittent failure on old Python version
SKIPPED [1] distributed/cli/tests/test_dask_scheduler.py:235: could not import 'bokeh': No module named 'bokeh'
SKIPPED [1] distributed/cli/tests/test_dask_worker.py:322: could not import 'bokeh': No module named 'bokeh'
SKIPPED [1] distributed/cli/tests/test_dask_worker.py:377: could not import 'bokeh': No module named 'bokeh'
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! stopping after 1 failures !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
================================== 41 passed, 28 skipped, 4 deselected, 1 warning, 1 error in 133.05s (0:02:13) ===================================
```

**Environment**:

- Dask version: 2.21.0
- Python version: 3.6.11 (it just happens to be the oldest we support, so it goes first on testing)
- Operating System: Gentoo Linux
- Install method (conda, pip, source): package manager

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Tests fail (unnecessarily) when networking is unavailable

Description

Contributor guide

Assessment

Get new issues in your inbox