diff --git a/pynumaflow/info/types.py b/pynumaflow/info/types.py index 4fa5b1b7..2845c264 100644 --- a/pynumaflow/info/types.py +++ b/pynumaflow/info/types.py @@ -77,15 +77,15 @@ class ContainerType(str, Enum): # To update this value, please follow the instructions for MINIMUM_NUMAFLOW_VERSION in # https://github.com/numaproj/numaflow-rs/blob/main/src/shared.rs MINIMUM_NUMAFLOW_VERSION = { - ContainerType.Sourcer: "1.3.0-z", - ContainerType.Sourcetransformer: "1.3.0-z", - ContainerType.Sinker: "1.3.0-z", - ContainerType.Mapper: "1.3.0-z", - ContainerType.Reducer: "1.3.0-z", - ContainerType.Reducestreamer: "1.3.0-z", - ContainerType.Sessionreducer: "1.3.0-z", - ContainerType.Sideinput: "1.3.0-z", - ContainerType.Fbsinker: "1.3.0-z", + ContainerType.Sourcer: "1.4.0-z", + ContainerType.Sourcetransformer: "1.4.0-z", + ContainerType.Sinker: "1.4.0-z", + ContainerType.Mapper: "1.4.0-z", + ContainerType.Reducer: "1.4.0-z", + ContainerType.Reducestreamer: "1.4.0-z", + ContainerType.Sessionreducer: "1.4.0-z", + ContainerType.Sideinput: "1.4.0-z", + ContainerType.Fbsinker: "1.4.0-z", } diff --git a/pyproject.toml b/pyproject.toml index 9be2836f..c4d6eba0 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "pynumaflow" -version = "0.8.0" +version = "0.9.0" description = "Provides the interfaces of writing Python User Defined Functions and Sinks for NumaFlow." authors = ["NumaFlow Developers"] readme = "README.md" diff --git a/tests/test_info_server.py b/tests/test_info_server.py index 70be5743..d05b78ed 100644 --- a/tests/test_info_server.py +++ b/tests/test_info_server.py @@ -39,7 +39,7 @@ def test_success_write_info(self): self.assertEqual(file_data["metadata"]["CPU_LIMIT"], "3") self.assertEqual(file_data["protocol"], "uds") self.assertEqual(file_data["language"], "python") - self.assertEqual(file_data["minimum_numaflow_version"], "1.3.0-z") + self.assertEqual(file_data["minimum_numaflow_version"], "1.4.0-z") def test_metadata_env(self): test_file = "/tmp/test_info_server"