We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
I just got a random test failure: https://github.com/dask/distributed/actions/runs/5650756106/job/15307671812?pr=8032
C:\Miniconda3\envs\dask-distributed\Lib\contextlib.py:81: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ C:\Miniconda3\envs\dask-distributed\Lib\contextlib.py:81: in inner return func(*args, **kwds) distributed\utils_test.py:1100: in test_func return _run_and_close_tornado(async_fn_outer) distributed\utils_test.py:378: in _run_and_close_tornado return asyncio_run(inner_fn(), loop_factory=get_loop_factory()) distributed\compatibility.py:204: in asyncio_run return runner.run(main) C:\Miniconda3\envs\dask-distributed\Lib\asyncio\runners.py:118: in run return self._loop.run_until_complete(task) C:\Miniconda3\envs\dask-distributed\Lib\asyncio\base_events.py:653: in run_until_complete return future.result() distributed\utils_test.py:375: in inner_fn return await async_fn(*args, **kwargs) distributed\utils_test.py:1097: in async_fn_outer return await utils_wait_for(async_fn(), timeout=timeout * 2) distributed\utils.py:1922: in wait_for return await fut distributed\utils_test.py:997: in async_fn async with _cluster_factory() as (s, workers), _client_factory( C:\Miniconda3\envs\dask-distributed\Lib\contextlib.py:211: in __aexit__ await anext(self.gen) distributed\utils_test.py:991: in _cluster_factory await end_cluster(s, workers) distributed\utils_test.py:857: in end_cluster await asyncio.gather(*(end_worker(w) for w in workers)) distributed\utils_test.py:855: in end_worker await w.close() distributed\utils.py:803: in wrapper return await func(*args, **kwargs) distributed\worker.py:1641: in close self.stop() distributed\core.py:668: in stop self.monitor.close() _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ self = <SystemMonitor: cpu: 0 memory: 173 MB fds: N/A> def close(self) -> None: if self.monitor_gil_contention: > self._gilknocker.stop() E UserWarning: Timed out waiting for sampling thread.
The text was updated successfully, but these errors were encountered:
Worker.close
milesgranger
No branches or pull requests
I just got a random test failure:
https://github.com/dask/distributed/actions/runs/5650756106/job/15307671812?pr=8032
The text was updated successfully, but these errors were encountered: