[Projects] Add Iguazio version validation for adding node selector to project

mlrun/projects/project.py

@@ -78,7 +78,10 @@
     clone_zip,
     get_repo_url,
 )
-from ..utils.helpers import ensure_git_branch, resolve_git_reference_from_source
+from ..utils.helpers import (
+    ensure_git_branch,
+    resolve_git_reference_from_source,
+)
 from ..utils.notifications import CustomNotificationPusher, NotificationTypes
 from .operations import (
     BuildStatus,
@@ -1272,6 +1275,14 @@ def description(self) -> str:
     def description(self, description):
         self.spec.description = description
 
+    @property
+    def default_function_node_selector(self) -> dict:
+        return self.spec.default_function_node_selector
+
+    @default_function_node_selector.setter
+    def default_function_node_selector(self, default_function_node_selector):
+        self.spec.default_function_node_selector = default_function_node_selector
+
     @property
     def default_image(self) -> str:
         return self.spec.default_image

mlrun/utils/helpers.py

@@ -983,6 +983,12 @@ def get_workflow_url(project, id=None):
     return url
 
 
+def is_igz_version_sufficient(required_version):
+    """Check if the installed Iguazio version is sufficient for the specified purpose."""
+    igz_version = mlrun.mlconf.get_parsed_igz_version()
+    return igz_version and igz_version >= semver.VersionInfo.parse(required_version)
+
+
 def are_strings_in_exception_chain_messages(
     exception: Exception, strings_list: list[str]
 ) -> bool:

server/api/utils/clients/iguazio.py

@@ -752,11 +752,22 @@ def _transform_mlrun_project_to_iguazio_project(
             body["data"]["attributes"]["owner_username"] = project.spec.owner
 
         if project.spec.default_function_node_selector is not None:
-            body["data"]["attributes"]["default_function_node_selector"] = (
-                Client._transform_mlrun_labels_to_iguazio_labels(
-                    project.spec.default_function_node_selector
+            # This feature requires support for project-level default_function_node_selector,
+            # which is available starting from version 3.5.5.
+            # We are adding this validation to maintain backward compatibility with older versions of Iguazio.
+            if mlrun.utils.helpers.is_igz_version_sufficient("3.5.5"):
+                body["data"]["attributes"]["default_function_node_selector"] = (
+                    Client._transform_mlrun_labels_to_iguazio_labels(
+                        project.spec.default_function_node_selector
+                    )
                 )
-            )
+            else:
+                logger.warning(
+                    "User attempted to use a feature requiring project-level default_function_node_selector,"
+                    " but the installed version of Iguazio is not compatible. "
+                    "Project created without the field in Iguazio."
+                )
+
         return body
 
     @staticmethod

tests/api/utils/clients/test_iguazio.py

@@ -19,6 +19,7 @@
 import http
 import json
 import typing
+import unittest.mock
 
 import deepdiff
 import fastapi
@@ -926,9 +927,14 @@ async def test_format_as_leader_project(
     iguazio_client: server.api.utils.clients.iguazio.Client,
 ):
     project = _generate_project()
-    iguazio_project = await maybe_coroutine(
-        iguazio_client.format_as_leader_project(project)
-    )
+    with unittest.mock.patch(
+        "mlrun.utils.helpers.is_igz_version_sufficient",
+        return_value=True,
+    ):
+        iguazio_project = await maybe_coroutine(
+            iguazio_client.format_as_leader_project(project)
+        )
+
     assert (
         deepdiff.DeepDiff(
             _build_project_response(iguazio_client, project, with_mlrun_project=True),
@@ -937,6 +943,7 @@ async def test_format_as_leader_project(
             exclude_paths=[
                 "root['attributes']['updated_at']",
                 "root['attributes']['operational_status']",
+                # "root['attributes']['default_function_node_selector']"
             ],
         )
         == {}

tests/projects/test_project.py

@@ -1262,7 +1262,7 @@ def test_function_receives_project_default_function_node_selector():
     )
     assert non_enriched_function.spec.node_selector == {}
 
-    proj1.spec.default_function_node_selector = default_function_node_selector
+    proj1.default_function_node_selector = default_function_node_selector
     enriched_function = proj1.get_function("func", enrich=True)
     assert enriched_function.spec.node_selector == default_function_node_selector