- update to 2024.11.1:

* Skip collecting coverage for CLI tests @fjetter
- update to 2024.11.0:
  * Remove redundant methods in P2PBarrierTask @fjetter
  * fix skipif condition for
    test\_tell\_workers\_when\_peers\_have\_left @fjetter
  * Ensure ConnectionPool closes even if network stack swallows
    cancellation @fjetter
  * Fix flaky test\_server\_comms\_mark\_active\_handlers
  * Make assumption in P2P's barrier mechanism explicit
  * Adjust timeouts in jupyter cli test @fjetter
  * Add `stimulus_id` to `SchedulerPlugin.update_graph` hook
  * Reduce P2P transfer task overhead @hendrikmakait
  * Disable profiler on python 3.11 @fjetter
  * Fix test\_restarting\_does\_not\_deadlock @fjetter
  * Adjust popen timeouts for testing @fjetter
  * Add retry to shuffle broadcast @fjetter
  * Fix test\_shuffle\_with\_array\_conversion @fjetter
  * Refactor some tests @fjetter
  * Reflect graduation of `dask-expr` from `dask-contrib` to
    `dask` @hendrikmakait
  * Skip test\_tell\_workers\_when\_peers\_have\_left on py3.10
  * Internal cleanup of P2P code @hendrikmakait
  * Use Task class instead of tuple @fjetter
  * Increase connect timeout for
    test\_tell\_workers\_when\_peers\_have\_left @fjetter
  * Remove dispatching in TaskCollection @fjetter
  * Deduplicate scheduler requests in P2P @hendrikmakait
  * Add configurations for rootish taskgroup threshold @phofl
- update to 2024.10.0:

OBS-URL: https://build.opensuse.org/package/show/devel:languages:python:numeric/python-distributed?expand=0&rev=178

.gitattributes

@@ -0,0 +1,23 @@
+## Default LFS
+*.7z filter=lfs diff=lfs merge=lfs -text
+*.bsp filter=lfs diff=lfs merge=lfs -text
+*.bz2 filter=lfs diff=lfs merge=lfs -text
+*.gem filter=lfs diff=lfs merge=lfs -text
+*.gz filter=lfs diff=lfs merge=lfs -text
+*.jar filter=lfs diff=lfs merge=lfs -text
+*.lz filter=lfs diff=lfs merge=lfs -text
+*.lzma filter=lfs diff=lfs merge=lfs -text
+*.obscpio filter=lfs diff=lfs merge=lfs -text
+*.oxt filter=lfs diff=lfs merge=lfs -text
+*.pdf filter=lfs diff=lfs merge=lfs -text
+*.png filter=lfs diff=lfs merge=lfs -text
+*.rpm filter=lfs diff=lfs merge=lfs -text
+*.tbz filter=lfs diff=lfs merge=lfs -text
+*.tbz2 filter=lfs diff=lfs merge=lfs -text
+*.tgz filter=lfs diff=lfs merge=lfs -text
+*.ttf filter=lfs diff=lfs merge=lfs -text
+*.txz filter=lfs diff=lfs merge=lfs -text
+*.whl filter=lfs diff=lfs merge=lfs -text
+*.xz filter=lfs diff=lfs merge=lfs -text
+*.zip filter=lfs diff=lfs merge=lfs -text
+*.zst filter=lfs diff=lfs merge=lfs -text

.gitignore

@@ -0,0 +1 @@
+.osc

_multibuild

@@ -0,0 +1,6 @@
+<multibuild>
+  <package>test-py310</package>
+  <package>test-py311</package>
+  <package>test-py312</package>
+  <package>test-py313</package>
+</multibuild>

distributed-2024.11.1-gh.tar.gz

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:c99e7f7664cffd3eb086241f1f8181a1b60d4fa8f24511353bf22cb698c48db1
+size 2574524

distributed-2024.4.2-gh.tar.gz

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:758411bf575fe312987a3d53a91de30c1fd6dd3e0603b0ff53d646fa2fc17647
+size 2552748

distributed-2024.6.2-gh.tar.gz

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:0abf6e182393bcc7d3b5f7ffa2af080d57c50bab6a1df044f7e5cde24982d131
+size 2556083

distributed-2024.8.1-gh.tar.gz

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:3f2de9ffe42d1d664077a68c00a94a3d9c6769b5e67714d4beb39f685e8b4bdf
+size 2569757

distributed-2024.8.2-gh.tar.gz

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:ccf497a5d3a90c2a9d39750494bcd8e0e57bf3c42ac3cd127498deae82f0d052
+size 2569934

distributed-ignore-offline.patch

@@ -0,0 +1,13 @@
+Index: distributed-2024.2.0/pyproject.toml
+===================================================================
+--- distributed-2024.2.0.orig/pyproject.toml
++++ distributed-2024.2.0/pyproject.toml
+@@ -117,7 +117,7 @@ filterwarnings = [
+     '''ignore:unclosed transport <_SelectorSocketTransport.*:ResourceWarning''',
+     '''ignore:unclosed transport <asyncio\.sslproto\..*:ResourceWarning''',
+     '''ignore:unclosed cluster SSHCluster.*:ResourceWarning''',
+-    '''ignore:Couldn't detect a suitable IP address for reaching '2001.4860.4860..8888', defaulting to hostname. \[Errno 65\] No route to host:RuntimeWarning''',
++    '''ignore:Couldn't detect a suitable IP address.*:RuntimeWarning''',
+     '''ignore:Dashboard and Scheduler are using the same server on port.*:RuntimeWarning''',
+     '''ignore:coroutine 'BaseTCPConnector.connect' was never awaited:RuntimeWarning''',
+     '''ignore:coroutine 'Client\._start' was never awaited:RuntimeWarning''',

distributed-ignore-rerun.patch

@@ -0,0 +1,15 @@
+Index: distributed-2024.2.0/distributed/distributed.yaml
+===================================================================
+--- distributed-2024.2.0.orig/distributed/distributed.yaml
++++ distributed-2024.2.0/distributed/distributed.yaml
+@@ -289,6 +289,10 @@ distributed:
+       ignore-files:
+         - runpy\.py  # `python -m pytest` (or other module) shell command
+         - pytest  # `pytest` shell command
++        - pytest-3\.9
++        - pytest-3\.10
++        - pytest-3\.11
++        - pytest_rerunfailures\.py
+         - py\.test  # `py.test` shell command
+         - pytest-script\.py  # `pytest` shell command in Windows
+         - _pytest  # pytest implementation

distributed-ignore-thread-leaks.patch

@@ -0,0 +1,13 @@
+Index: distributed-2024.2.0/distributed/utils_test.py
+===================================================================
+--- distributed-2024.2.0.orig/distributed/utils_test.py
++++ distributed-2024.2.0/distributed/utils_test.py
+@@ -1644,7 +1644,7 @@ def check_thread_leak():
+     yield
+ 
+     start = time()
+-    while True:
++    while False:
+         bad_threads = [
+             thread
+             for thread in threading.enumerate()

python-distributed-rpmlintrc

@@ -0,0 +1 @@
+addFilter("explicit-lib-dependency python3.*-tblib")

python-distributed.spec

@@ -0,0 +1,246 @@
+#
+# spec file for package python-distributed
+#
+# Copyright (c) 2024 SUSE LLC
+#
+# All modifications and additions to the file contributed by third parties
+# remain the property of their copyright owners, unless otherwise agreed
+# upon. The license for this file, and modifications and additions to the
+# file, is the same license as for the pristine package itself (unless the
+# license for the pristine package is not an Open Source License, in which
+# case the license is the MIT License). An "Open Source License" is a
+# license that conforms to the Open Source Definition (Version 1.9)
+# published by the Open Source Initiative.
+
+# Please submit bugfixes or comments via https://bugs.opensuse.org/
+#
+
+
+%global flavor @BUILD_FLAVOR@%{nil}
+%{?sle15_python_module_pythons}
+%if "%{flavor}" == ""
+%define psuffix %{nil}
+%bcond_with test
+%else
+%bcond_without test
+%define psuffix -%{flavor}
+%if 0%{suse_version} >= 1599
+%if "%{flavor}" != "test-py310"
+%define skip_python310 1
+%endif
+%if "%{flavor}" != "test-py311"
+%define skip_python311 1
+%endif
+%if "%{flavor}" != "test-py312"
+%define skip_python312 1
+%endif
+%if "%{flavor}" != "test-py313"
+%define skip_python313 1
+%endif
+%else
+%if "%{pythons}" == "python311" && "%{flavor}" != "test-py311"
+# Hardcoded assumption: SLE15 pythons module has python311
+%define pythons %{nil}
+%endif
+%endif
+%endif
+%if "%{shrink:%pythons}" == ""
+ExclusiveArch:  donotbuild
+%define python_module() %flavor-not-enabled-in-buildset-for-suse-%{?suse_version}
+%endif
+
+# use this to run tests with xdist in parallel, unfortunately fails server side
+%bcond_with paralleltests
+
+Name:           python-distributed%{psuffix}
+# ===> Note: python-dask MUST be updated in sync with python-distributed! <===
+Version:        2024.11.1
+Release:        0
+Summary:        Library for distributed computing with Python
+License:        BSD-3-Clause
+URL:            https://distributed.dask.org
+# SourceRepository: https://github.com/dask/distributed
+Source:         https://github.com/dask/distributed/archive/refs/tags/%{version}.tar.gz#/distributed-%{version}-gh.tar.gz
+Source99:       python-distributed-rpmlintrc
+# PATCH-FIX-OPENSUSE distributed-ignore-off.patch -- ignore that we can't probe addresses on obs, code@bnavigator.de
+Patch3:         distributed-ignore-offline.patch
+# PATCH-FIX-OPENSUSE distributed-ignore-thread-leaks.patch -- ignore leaking threads on obs, code@bnavigator.de
+Patch4:         distributed-ignore-thread-leaks.patch
+# PATCH-FIX-OPENSUSE distributed-ignore-rerun.patch -- extend ignore pytest array, mimi.vx@gmail.com
+Patch5:         distributed-ignore-rerun.patch
+BuildRequires:  %{python_module base >= 3.10}
+BuildRequires:  %{python_module pip}
+BuildRequires:  %{python_module setuptools}
+BuildRequires:  %{python_module versioneer-toml >= 0.29}
+BuildRequires:  %{python_module wheel}
+BuildRequires:  fdupes
+BuildRequires:  python-rpm-macros
+Requires:       python-Jinja2 >= 2.10.3
+Requires:       python-PyYAML >= 5.4.1
+Requires:       python-click >= 8.0
+Requires:       python-cloudpickle >= 3.0.0
+Requires:       python-dask = %{version}
+Requires:       python-locket >= 1.0.0
+Requires:       python-msgpack >= 1.0.2
+Requires:       python-packaging >= 20.0
+Requires:       python-psutil >= 5.8.0
+Requires:       python-sortedcontainers >= 2.0.5
+Requires:       python-tblib >= 1.6.0
+Requires:       python-toolz >= 0.11.2
+Requires:       python-tornado >= 6.2.0
+Requires:       python-urllib3 >= 1.26.5
+Requires:       python-zict >= 2.2.0
+Requires(post): update-alternatives
+Requires(postun): update-alternatives
+BuildArch:      noarch
+%if %{with test}
+BuildRequires:  %{python_module bokeh >= 3.1}
+BuildRequires:  %{python_module dask-complete = %{version}}
+BuildRequires:  %{python_module distributed = %{version}}
+BuildRequires:  %{python_module ipykernel}
+BuildRequires:  %{python_module ipython}
+BuildRequires:  %{python_module jupyter_client}
+BuildRequires:  %{python_module pytest-rerunfailures}
+BuildRequires:  %{python_module pytest-timeout}
+BuildRequires:  %{python_module pytest}
+BuildRequires:  %{python_module requests}
+BuildRequires:  %{python_module sparse}
+BuildRequires:  %{python_module zict >= 3}
+%if %{with paralleltests}
+BuildRequires:  %{python_module pytest-xdist}
+%endif
+%endif
+%python_subpackages
+
+%description
+Dask.distributed is a library for distributed computing in Python. It
+extends both the concurrent.futures and dask APIs to moderate sized
+clusters.
+
+%prep
+%autosetup -p1 -n distributed-%{version}
+
+sed -e '/--durations=20/d' \
+    -e '/--color=yes/d'  \
+    -e '/--cov/d'  \
+    -e 's/timeout_method = thread/timeout_method = signal/' \
+    -i pyproject.toml
+
+%build
+%if ! %{with test}
+%pyproject_wheel
+%endif
+
+%install
+%if ! %{with test}
+%pyproject_install
+%python_clone -a %{buildroot}%{_bindir}/dask-ssh
+%python_clone -a %{buildroot}%{_bindir}/dask-scheduler
+%python_clone -a %{buildroot}%{_bindir}/dask-worker
+%python_expand %fdupes %{buildroot}%{$python_sitelib}
+%endif
+
+%if %{with test}
+%check
+# test local src dir, not installed path: looks for test certificates and not installed test modules
+export PYTHONPATH=":x"
+# disable profiling completely -- https://github.com/dask/distributed/pull/6490
+sed '/enable profiling/ {s/enabled: True/enabled: False/}' -i distributed/distributed.yaml
+# make sure the change was successful, this is only for the tests, we didn't patch any installed source
+grep 'enabled: False .*enable profiling' distributed/distributed.yaml
+
+# we obviously don't test a git repo
+donttest="test_git_revision"
+# logger error
+donttest+=" or test_version_warning_in_cluster"
+# invalid task state
+donttest+=" or test_fail_to_pickle_execute_2"
+# too slow for obs
+donttest+=" or test_nanny_timeout"
+
+# Some tests randomly fail server-side -- too slow for obs (?)
+# see also https://github.com/dask/distributed/issues/5818
+donttest+=" or (test_asyncprocess and (test_exit_callback or test_simple))"
+donttest+=" or (test_client and test_repr)"
+donttest+=" or (test_client and test_profile_server)"
+donttest+=" or (test_client and test_forget_errors)"
+donttest+=" or (test_dask_collections and test_sparse_arrays)"
+donttest+=" or (test_metrics and test_wall_clock)"
+donttest+=" or (test_nanny and test_failure_during_worker_initialization)"
+donttest+=" or (test_priorities and test_compute)"
+donttest+=" or (test_resources and test_prefer_constrained)"
+donttest+=" or (test_scheduler and test_tell_workers_when_peers_have_left)"
+donttest+=" or (test_steal and test_steal_twice)"
+donttest+=" or (test_utils and test_popen_timeout)"
+donttest+=" or (test_variable and test_variable_in_task)"
+donttest+=" or (test_worker and test_gather_dep_from_remote_workers_if_all_local_workers_are_busy)"
+donttest+=" or (test_worker and test_worker_reconnects_mid_compute)"
+donttest+=" or (test_worker_memory and test_digests)"
+donttest+=" or (test_worker_memory and test_pause_while_spilling)"
+donttest+=" or test_computations_futures"
+donttest+=" or test_task_state_instance_are_garbage_collected"
+donttest+=" or test_computation_object_code_client_submit_list_comp"
+donttest+=" or test_computation_object_code_client_submit_dict_comp"
+# server-side fail due to the non-network warning in a subprocess where the patched filter does not apply
+donttest+=" or (test_client and test_quiet_close_process)"
+# should return > 3, returns 3 exactly
+donttest+=" or (test_statistical_profiling_cycle)"
+# pytest7 on py312: returns len==2 instead of 1
+donttest+=" or test_computation_object_code_dask_compute"
+# flakey on 3.10
+donttest+=" or (test_client_worker)"
+if [[ $(getconf LONG_BIT) -eq 32 ]]; then
+  # OverflowError -- https://github.com/dask/distributed/issues/5252
+  donttest+=" or test_ensure_spilled_immediately"
+  donttest+=" or test_value_raises_during_spilling"
+  donttest+=" or test_fail_to_pickle_execute_1"
+  # https://github.com/dask/distributed/issues/7175
+  donttest+=" or (test_sizeof_error and larger)"
+  #
+  donttest+=" or test_task_groups"
+fi
+
+%if %{with paralleltests}
+# not fully supported parallel test suite: https://github.com/dask/distributed/issues/5186
+# works locally, but fails with too many tests server-side
+notparallel="rebalance or memory or upload"
+notparallel+=" or test_open_close_many_workers"
+notparallel+=" or test_recreate_error_array"
+notparallel+=" or (test_preload and test_web_preload)"
+#  Recursion error, https://github.com/dask/distributed/issues/6406
+notparallel+=" or test_stack_overflow"
+#
+notparallel+=" or test_dashboard_host"
+notparallel+=" or test_close_properly"
+notparallel+=" or test_plugin_internal_exception"
+notparallel+=" or test_runspec_regression_sync"
+notparallel+=" or test_client_async_before_loop_starts"
+# added in 2023.5.1
+notparallel+=" or test_ensure_no_new_clients"
+
+%pytest distributed/tests -m "not avoid_ci" -n auto -k "not ($notparallel or $donttest ${$python_donttest})"
+%pytest distributed/tests -m "not avoid_ci" -k "($notparallel) and not ($donttest ${$python_donttest})"
+%else
+%pytest distributed/tests -m "not avoid_ci" -k "not ($donttest ${$python_donttest})"
+%endif
+%endif
+
+%if ! %{with test}
+%post
+%python_install_alternative dask-ssh dask-scheduler dask-worker
+
+%postun
+%python_uninstall_alternative dask-ssh
+
+%files %{python_files}
+%doc README.rst
+%license LICENSE.txt
+%python_alternative %{_bindir}/dask-ssh
+%python_alternative %{_bindir}/dask-scheduler
+%python_alternative %{_bindir}/dask-worker
+%{python_sitelib}/distributed
+%{python_sitelib}/distributed-%{version}.dist-info
+
+%endif
+
+%changelog