From 0b030a161bd4bebd1fcb1c2e5265690f9ef773ec Mon Sep 17 00:00:00 2001 From: GALI PREM SAGAR Date: Tue, 2 Aug 2022 11:42:26 -0500 Subject: [PATCH] Fix `distributed` error related to `loop_in_thread` (#11428) This PR resolves the following error showing up in latest `distributed`: ```python python/dask_cudf/dask_cudf/tests/test_distributed.py EE [100%] =========================================================================================== ERRORS =========================================================================================== _____________________________________________________________________________ ERROR at setup of test_basic[True] _____________________________________________________________________________ file /nvme/0/pgali/cudf/python/dask_cudf/dask_cudf/tests/test_distributed.py, line 24 @pytest.mark.parametrize("delayed", [True, False]) def test_basic(loop, delayed): # noqa: F811 file /nvme/0/pgali/envs/cudfdev/lib/python3.9/site-packages/distributed/utils_test.py, line 145 @pytest.fixture def loop(loop_in_thread): E fixture 'loop_in_thread' not found > available fixtures: benchmark, benchmark_weave, cache, capfd, capfdbinary, caplog, capsys, capsysbinary, cleanup, current_cases, doctest_namespace, loop, monkeypatch, pytestconfig, record_property, record_testsuite_property, record_xml_attribute, recwarn, testrun_uid, tmp_path, tmp_path_factory, tmpdir, tmpdir_factory, worker_id > use 'pytest --fixtures [testpath]' for help on them. /nvme/0/pgali/envs/cudfdev/lib/python3.9/site-packages/distributed/utils_test.py:145 ____________________________________________________________________________ ERROR at setup of test_basic[False] _____________________________________________________________________________ file /nvme/0/pgali/cudf/python/dask_cudf/dask_cudf/tests/test_distributed.py, line 24 @pytest.mark.parametrize("delayed", [True, False]) def test_basic(loop, delayed): # noqa: F811 file /nvme/0/pgali/envs/cudfdev/lib/python3.9/site-packages/distributed/utils_test.py, line 145 @pytest.fixture def loop(loop_in_thread): E fixture 'loop_in_thread' not found > available fixtures: benchmark, benchmark_weave, cache, capfd, capfdbinary, caplog, capsys, capsysbinary, cleanup, current_cases, doctest_namespace, loop, monkeypatch, pytestconfig, record_property, record_testsuite_property, record_xml_attribute, recwarn, testrun_uid, tmp_path, tmp_path_factory, tmpdir, tmpdir_factory, worker_id > use 'pytest --fixtures [testpath]' for help on them. ``` Authors: - GALI PREM SAGAR (https://github.com/galipremsagar) Approvers: - Charles Blackmon-Luca (https://github.com/charlesbluca) URL: https://github.com/rapidsai/cudf/pull/11428 --- python/dask_cudf/dask_cudf/tests/test_distributed.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/dask_cudf/dask_cudf/tests/test_distributed.py b/python/dask_cudf/dask_cudf/tests/test_distributed.py index 564ad570f87..e24feaa2ea4 100644 --- a/python/dask_cudf/dask_cudf/tests/test_distributed.py +++ b/python/dask_cudf/dask_cudf/tests/test_distributed.py @@ -6,7 +6,7 @@ import dask from dask import dataframe as dd from dask.distributed import Client -from distributed.utils_test import cleanup, loop # noqa: F401 +from distributed.utils_test import cleanup, loop, loop_in_thread # noqa: F401 import cudf from cudf.testing._utils import assert_eq