chore: support Python 3.13 (#245)

Signed-off-by: Kevin Neal <Kevin_Neal@intuit.com>

Author: khneal

.github/workflows/run-tests.yml

@@ -13,7 +13,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python-version: ["3.9", "3.10", "3.11", "3.12"]
+        python-version: ["3.9", "3.10", "3.11", "3.12", "3.13"]
 
     steps:
     - uses: actions/checkout@v3

poetry.lock

@@ -16,20 +16,21 @@ classifiers = [
     "Programming Language :: Python :: 3.9",
     "Programming Language :: Python :: 3.10",
     "Programming Language :: Python :: 3.11",
-    "Programming Language :: Python :: 3.12"
+    "Programming Language :: Python :: 3.12",
+    "Programming Language :: Python :: 3.13"
 ]
 repository = "https://github.com/numaproj/numaflow-python"
 
 [tool.poetry.dependencies]
-python = ">=3.9, <3.13"
+python = ">=3.9, <3.14"
 grpcio = "^1.48.1"
 grpcio-tools = "^1.48.1"
 google-cloud = "^0.34.0"
 google-api-core = "^2.11.0"
 grpcio-status = "^1.48.1"
-protobuf = ">=3.20,<6.0"
+protobuf = ">=3.20,<7.0"
 aiorun = "^2023.7"
-uvloop = "^0.19.0"
+uvloop = "^0.21.0"
 psutil = "^6.0.0"
 
 [tool.poetry.group.dev]

pyproject.toml

@@ -136,10 +136,10 @@ def test_map_forward_message(self):
 
         self.assertTrue(responses[0].handshake.sot)
 
+        result_ids = {f"test-id-{id}" for id in range(1, 4)}
         idx = 1
         while idx < len(responses):
-            _id = "test-id-" + str(idx)
-            self.assertEqual(_id, responses[idx].id)
+            result_ids.remove(responses[idx].id)
             self.assertEqual(
                 bytes(
                     "payload:test_mock_message "
@@ -150,6 +150,7 @@ def test_map_forward_message(self):
             )
             self.assertEqual(1, len(responses[idx].results))
             idx += 1
+        self.assertEqual(len(result_ids), 0)
         self.assertEqual(code, StatusCode.OK)
 
     def test_invalid_input(self):

tests/map/test_multiproc_mapper.py

@@ -130,10 +130,10 @@ def test_map_forward_message(self):
 
         self.assertTrue(responses[0].handshake.sot)
 
+        result_ids = {f"test-id-{id}" for id in range(1, 4)}
         idx = 1
         while idx < len(responses):
-            _id = "test-id-" + str(idx)
-            self.assertEqual(_id, responses[idx].id)
+            result_ids.remove(responses[idx].id)
             self.assertEqual(
                 bytes(
                     "payload:test_mock_message "
@@ -144,6 +144,7 @@ def test_map_forward_message(self):
             )
             self.assertEqual(1, len(responses[idx].results))
             idx += 1
+        self.assertEqual(len(result_ids), 0)
         self.assertEqual(code, StatusCode.OK)
 
     def test_invalid_input(self):

tests/map/test_sync_mapper.py

@@ -162,10 +162,10 @@ def test_mapt_assign_new_event_time(self):
 
         self.assertTrue(responses[0].handshake.sot)
 
+        result_ids = {f"test-id-{id}" for id in range(1, 4)}
         idx = 1
         while idx < len(responses):
-            _id = "test-id-" + str(idx)
-            self.assertEqual(_id, responses[idx].id)
+            result_ids.remove(responses[idx].id)
             self.assertEqual(
                 bytes(
                     "payload:test_mock_message " "event_time:2022-09-12 16:00:00 ",
@@ -175,6 +175,7 @@ def test_mapt_assign_new_event_time(self):
             )
             self.assertEqual(1, len(responses[idx].results))
             idx += 1
+        self.assertEqual(len(result_ids), 0)
 
         # Verify new event time gets assigned.
         updated_event_time_timestamp = _timestamp_pb2.Timestamp()

tests/sourcetransform/test_multiproc.py

@@ -153,10 +153,10 @@ def test_mapt_assign_new_event_time(self):
 
         self.assertTrue(responses[0].handshake.sot)
 
+        result_ids = {f"test-id-{id}" for id in range(1, 4)}
         idx = 1
         while idx < len(responses):
-            _id = "test-id-" + str(idx)
-            self.assertEqual(_id, responses[idx].id)
+            result_ids.remove(responses[idx].id)
             self.assertEqual(
                 bytes(
                     "payload:test_mock_message " "event_time:2022-09-12 16:00:00 ",
@@ -166,6 +166,7 @@ def test_mapt_assign_new_event_time(self):
             )
             self.assertEqual(1, len(responses[idx].results))
             idx += 1
+        self.assertEqual(len(result_ids), 0)
 
         # Verify new event time gets assigned.
         updated_event_time_timestamp = _timestamp_pb2.Timestamp()