Renames "runtime" on the "backend" in the operator merged specification (#483)

Author: mrDzurb

ads/opctl/operator/cmd.py

@@ -32,6 +32,7 @@
     OPERATOR_BASE_DOCKER_GPU_FILE,
     OPERATOR_BASE_GPU_IMAGE,
     OPERATOR_BASE_IMAGE,
+    OPERATOR_BACKEND_SECTION_NAME
 )
 from ads.opctl.operator.common.operator_loader import OperatorInfo, OperatorLoader
 from ads.opctl.utils import publish_image as publish_image_cmd
@@ -204,7 +205,7 @@ def init(
     ).items():
         tmp_config = value
         if merge_config and operator_config:
-            tmp_config = {**operator_config, "runtime": value}
+            tmp_config = {**operator_config, OPERATOR_BACKEND_SECTION_NAME: value}
 
         with fsspec.open(
             os.path.join(

ads/opctl/operator/common/backend_factory.py

@@ -28,7 +28,7 @@
     RESOURCE_TYPE,
     RUNTIME_TYPE,
 )
-from ads.opctl.operator.common.const import PACK_TYPE
+from ads.opctl.operator.common.const import PACK_TYPE, OPERATOR_BACKEND_SECTION_NAME
 from ads.opctl.operator.common.dictionary_merger import DictionaryMerger
 from ads.opctl.operator.common.operator_loader import OperatorInfo, OperatorLoader
 
@@ -124,14 +124,14 @@ def backend(
                 f"The `type` attribute must be specified in the operator's config."
             )
 
-        if not backend and not config.config.get("runtime"):
+        if not backend and not config.config.get(OPERATOR_BACKEND_SECTION_NAME):
             logger.info(
                 f"Backend config is not provided, the {BACKEND_NAME.LOCAL.value} "
                 "will be used by default. "
             )
             backend = BACKEND_NAME.LOCAL.value
         elif not backend:
-            backend = config.config.get("runtime")
+            backend = config.config.get(OPERATOR_BACKEND_SECTION_NAME)
 
         # extracting details about the operator
         operator_info = OperatorLoader.from_uri(uri=operator_type).load()
@@ -211,9 +211,9 @@ def backend(
         config.config["infrastructure"] = p_backend.config["infrastructure"]
         config.config["execution"] = p_backend.config["execution"]
 
-        return cls.BACKEND_MAP[p_backend.config["execution"]["backend"].lower()](
-            config=config.config, operator_info=operator_info
-        )
+        return cls.BACKEND_MAP[
+            p_backend.config["execution"][OPERATOR_BACKEND_SECTION_NAME].lower()
+        ](config=config.config, operator_info=operator_info)
 
     @classmethod
     def _extract_backend(

ads/opctl/operator/common/const.py

@@ -15,6 +15,7 @@
 OPERATOR_BASE_DOCKER_FILE = "Dockerfile"
 OPERATOR_BASE_DOCKER_GPU_FILE = "Dockerfile.gpu"
 
+OPERATOR_BACKEND_SECTION_NAME = "backend"
 
 class PACK_TYPE(str, metaclass=ExtendedEnumMeta):
     SERVICE = "service"

ads/opctl/operator/common/operator_config.py

@@ -30,15 +30,15 @@ class OperatorConfig(DataClassSerializable):
         The version of the operator.
     spec: object
         The operator specification details.
-    runtime: dict
-        The runtime details of the operator.
+    backend: dict
+        The operator's backend details.
     """
 
     kind: str = "operator"
     type: str = None
     version: str = None
     spec: Any = None
-    runtime: Dict = None
+    backend: Dict = None
 
     @classmethod
     def _validate_dict(cls, obj_dict: Dict) -> bool: