Merge branch 'master' into sandbox-no-conda

Author: martindurant

.github/workflows/main.yaml

@@ -13,7 +13,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        CONDA_ENV: [py39, py310, py311, py312]
+        CONDA_ENV: [py39, py310, py311, py312, py313, py314]
     # env:
       # STREAMZ_LAUNCH_KAFKA: true
 

ci/environment-py313.yml

@@ -0,0 +1,27 @@
+name: test_env
+channels:
+  - conda-forge
+  - defaults
+dependencies:
+  - python=3.13
+  - pytest
+  - flake8
+  - black
+  - isort
+  - tornado
+  - toolz
+  - librdkafka
+  - dask
+  - distributed
+  - pandas
+  - python-confluent-kafka
+  - codecov
+  - coverage
+  - networkx
+  - graphviz
+  - pytest-asyncio
+  - python-graphviz
+  - bokeh
+  - ipywidgets
+  - flaky
+  - pytest-cov

ci/environment-py314.yml

@@ -0,0 +1,27 @@
+name: test_env
+channels:
+  - conda-forge
+  - defaults
+dependencies:
+  - python=3.14
+  - pytest
+  - flake8
+  - black
+  - isort
+  - tornado
+  - toolz
+  - librdkafka
+  - dask
+  - distributed
+  - pandas
+  - python-confluent-kafka
+  - codecov
+  - coverage
+  - networkx
+  - graphviz
+  - pytest-asyncio
+  - python-graphviz
+  - bokeh
+  - ipywidgets
+  - flaky
+  - pytest-cov

streamz/orderedweakset.py

@@ -26,6 +26,9 @@ def add(self, value):
     def discard(self, value):
         self._od.pop(value, None)
 
+    def copy(self):
+        return OrderedSet(self._od.copy())
+
 
 class OrderedWeakrefSet(weakref.WeakSet):
     def __init__(self, values=()):

streamz/tests/test_sources.py

@@ -103,7 +103,7 @@ def test_http():
 def test_process():
     cmd = ["python", "-c", "for i in range(4): print(i, end='')"]
     s = Source.from_process(cmd, with_end=True)
-    if sys.platform != "win32":
+    if sys.platform != "win32" and sys.version_info < (3, 14):
         # don't know why - something with pytest and new processes
         policy = asyncio.get_event_loop_policy()
         watcher = asyncio.SafeChildWatcher()
@@ -119,7 +119,7 @@ def test_process():
 def test_process_str():
     cmd = 'python -c "for i in range(4): print(i)"'
     s = Source.from_process(cmd)
-    if sys.platform != "win32":
+    if sys.platform != "win32" and sys.version_info < (3, 14):
         # don't know why - something with pytest and new processes
         policy = asyncio.get_event_loop_policy()
         watcher = asyncio.SafeChildWatcher()