[streampipes] branch dev updated: chore(#1103): add 3.11 to supported Python versions (#1705)

[bo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

bossenti pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new d7c59d4cf chore(#1103): add 3.11 to supported Python versions (#1705)
d7c59d4cf is described below

commit d7c59d4cf44123e497652e444098738d23a0df4a
Author: Tim <50...@users.noreply.github.com>
AuthorDate: Mon Aug 7 12:20:14 2023 +0200

    chore(#1103): add 3.11 to supported Python versions (#1705)
---
 .github/workflows/pr-validation.yml                               | 2 +-
 streampipes-client-python/setup.py                                | 6 ++++--
 .../streampipes/functions/utils/async_iter_handler.py             | 8 +++++---
 3 files changed, 10 insertions(+), 6 deletions(-)

diff --git a/.github/workflows/pr-validation.yml b/.github/workflows/pr-validation.yml
index 6544d1684..45f02be67 100644
--- a/.github/workflows/pr-validation.yml
+++ b/.github/workflows/pr-validation.yml
@@ -139,7 +139,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python: [3.8, 3.9, "3.10"]
+        python: [3.8, 3.9, "3.10", "3.11"]
         os: [ubuntu-latest, macos-latest, windows-latest]
 
     steps:
diff --git a/streampipes-client-python/setup.py b/streampipes-client-python/setup.py
index 468200354..e7bb800d3 100644
--- a/streampipes-client-python/setup.py
+++ b/streampipes-client-python/setup.py
@@ -41,7 +41,8 @@ base_packages = [
     "pandas~=1.5",
     "pydantic~=1.10",
     "requests~=2.28",
-    "nats-py~=2.2",
+    "nats-py~=2.2;  python_version <= '3.10'",
+    "nats-py~=2.3.0;  python_version == '3.11'",
     "confluent-kafka~=2.0",
     "typing-extensions~=4.5",
 ]
@@ -130,8 +131,9 @@ setuptools.setup(
         "Programming Language :: Python :: 3.8",
         "Programming Language :: Python :: 3.9",
         "Programming Language :: Python :: 3.10",
+        "Programming Language :: Python :: 3.11",
         "Topic :: Scientific/Engineering"
     ],
     ext_modules=[],
-    keywords='streampipes, iot, iiot, analytics, stream-processing, apache',
+    keywords='streampipes, iot, iiot, analytics, stream-processing, online-ml, apache',
 )
diff --git a/streampipes-client-python/streampipes/functions/utils/async_iter_handler.py b/streampipes-client-python/streampipes/functions/utils/async_iter_handler.py
index 62a742d5b..0c90e7859 100644
--- a/streampipes-client-python/streampipes/functions/utils/async_iter_handler.py
+++ b/streampipes-client-python/streampipes/functions/utils/async_iter_handler.py
@@ -56,11 +56,13 @@ class AsyncIterHandler:
         message: Tuple[str, Any]
             Description of the anonymous integer return value.
         """
-        pending = {AsyncIterHandler.anext(stream_id, message) for stream_id, message in messages.items()}
+        pending = {
+            asyncio.create_task(AsyncIterHandler.anext(stream_id, message)) for stream_id, message in messages.items()
+        }
         while pending:
-            done, pending = await asyncio.wait(pending, return_when=asyncio.FIRST_COMPLETED)  # type: ignore
+            done, pending = await asyncio.wait(pending, return_when=asyncio.FIRST_COMPLETED)
             for i in done:
                 stream_id, msg = i.result()
                 if stream_id != "stop":
-                    pending.add(AsyncIterHandler.anext(stream_id, messages[stream_id]))
+                    pending.add(asyncio.create_task(AsyncIterHandler.anext(stream_id, messages[stream_id])))
                 yield stream_id, msg