Remove redundant skips
@@ -38,8 +38,6 @@ def slow_raise_value_error(condition, duration=0.05):
def test_simple(loop, joblib):
- if joblib is None:
- pytest.skip()
Parallel = joblib.Parallel
delayed = joblib.delayed
with cluster() as (s, [a, b]):
@@ -61,8 +59,6 @@ def random2():
def test_dont_assume_function_purity(loop, joblib):
- if joblib is None:
- pytest.skip()
Parallel = joblib.Parallel
delayed = joblib.delayed
with cluster() as (s, [a, b]):
@@ -73,8 +69,6 @@ def test_dont_assume_function_purity(loop, joblib):
def test_joblib_funcname(joblib):
- if joblib is None:
- pytest.skip()
BatchedCalls = joblib.parallel.BatchedCalls
if LooseVersion(joblib.__version__) <= "0.11.0":
func = BatchedCalls([(random2,), (random2,)])
@@ -85,9 +79,6 @@ def test_joblib_funcname(joblib):
def test_joblib_backend_subclass(joblib):
- if joblib is None:
- pytest.skip()
-
assert issubclass(distributed_joblib.DaskDistributedBackend,
joblib.parallel.ParallelBackendBase)
@@ -112,9 +103,6 @@ class CountSerialized(object):
def test_joblib_scatter(loop, joblib):
- if joblib is None:
- pytest.skip()
-
Parallel = joblib.Parallel
delayed = joblib.delayed
@@ -149,8 +137,8 @@ def test_joblib_scatter(loop, joblib):
def test_nested_backend_context_manager(loop, joblib):
- if joblib is None or LooseVersion(joblib.__version__) <= "0.11.0":
- pytest.skip("Joblib >= 0.11.1 required.")
+ if LooseVersion(joblib.__version__) <= "0.11.0":
+ pytest.skip("Joblib >= 0.11.1 required for nested parallelism.")
Parallel = joblib.Parallel
delayed = joblib.delayed
@@ -181,9 +169,6 @@ def test_nested_backend_context_manager(loop, joblib):
def test_errors(loop, joblib):
- if joblib is None:
- pytest.skip()
-
with pytest.raises(ValueError) as info:
with joblib.parallel_backend('dask'):
pass
