refactor(core)!: use class decorators for explore operators and add OperatorMetadata

examples/ml-multi-cloud/EXAMPLE_SIMPLE.md

@@ -243,10 +243,8 @@ The operation will end with information like:
 config:
   operation:
     module:
-      moduleClass: RandomWalk
-      moduleName: orchestrator.modules.operators.randomwalk
-      modulePath: .
-      moduleType: operation
+      operatorName: random_walk
+      operationType: search
     parameters:
       batchSize: 1
       numberEntities: 48

examples/optimization_test_functions/README.md

@@ -280,10 +280,8 @@ Operation:
   metadata: {}
   operation:
     module:
-      moduleClass: RayTune
-      moduleName: ado_ray_tune.operator
-      modulePath: .
-      moduleType: operation
+      operatorName: ray_tune
+      operationType: search
     parameters:
       tuneConfig:
         max_concurrent_trials: 2

examples/pfas-generative-models/operation_transformer_benchmark.yaml

@@ -4,7 +4,8 @@ spaces:
   - 'space-abcdef-123456' # Replace with space id from space_transformer_with_objective.yaml
 operation:
   module:
-    moduleClass: "RandomWalk"
+    operatorName: "random_walk"
+    operationType: "search"
   parameters:
     numberEntities: 43000
     batchSize: 1000

orchestrator/cli/resources/operation/template.py

@@ -21,7 +21,7 @@
     DiscoveryOperationConfiguration,
     DiscoveryOperationEnum,
     DiscoveryOperationResourceConfiguration,
-    OperatorFunctionConf,
+    OperatorReference,
 )
 
 
@@ -103,12 +103,13 @@ def template_operation(parameters: AdoTemplateCommandParameters) -> None:
 
     # We are now sure that the operator_type is supported and
     # has a value
-    default_operation_parameters = operators[
-        parameters.operator_type
-    ].default_configuration_model_for_operation(parameters.operator_name)
+    operator = operators[parameters.operator_type].operators.get(
+        parameters.operator_name
+    )
+    default_operation_parameters = operator.example_configuration if operator else None
 
     # Certain operators may not have a default configuration model
-    # Use an OperatorFunctionConf and set the values we have
+    # Use an OperatorReference and set the values we have
     if not default_operation_parameters:
 
         console_print(
@@ -119,7 +120,7 @@ def template_operation(parameters: AdoTemplateCommandParameters) -> None:
         default_operation_parameters = {}
 
     default_operation_configuration = DiscoveryOperationConfiguration(
-        module=OperatorFunctionConf(
+        module=OperatorReference(
             operatorName=parameters.operator_name,
             operationType=parameters.operator_type,
         ),
@@ -181,5 +182,5 @@ def operator_type_has_operator(
         operator_name
         in orchestrator.modules.operators.collections.operationCollectionMap[
             operator_type
-        ].function_operations
+        ].operators
     )

orchestrator/cli/resources/operator/get.py

@@ -42,22 +42,46 @@ def get_operator(parameters: AdoGetCommandParameters) -> None:
         )
         parameters.output_format = AdoGetSupportedOutputFormats.TABLE
 
-    # Build entries for DataFrame
+    # Handle NAME output format
+    if parameters.output_format == AdoGetSupportedOutputFormats.NAME:
+
+        # Collect all operator names
+        operator_names = []
+        for (
+            collection
+        ) in orchestrator.modules.operators.collections.operationCollectionMap.values():
+            operator_names.extend(collection.operators.keys())
+
+        if parameters.resource_id:
+            # Single operator: verify it exists and output its name
+            if parameters.resource_id not in operator_names:
+                console_print(
+                    f"{ERROR}{parameters.resource_id} is not among the available operators.\n"
+                    f"{HINT}Run {cyan('ado get operators')} to list them.",
+                    stderr=True,
+                )
+                raise typer.Exit(1)
+            console_print(parameters.resource_id)
+        else:
+            # Multiple operators: output all names
+            for operator_name in sorted(operator_names):
+                console_print(operator_name)
+        return
+
+    # Build entries for TABLE format
     entries = []
     for (
         collection
     ) in orchestrator.modules.operators.collections.operationCollectionMap.values():
-        for function_name in collection.function_operations:
+        for operator_name, operator in collection.operators.items():
             entry = {
-                "OPERATOR": function_name,
-                "VERSION": collection.function_operation_versions.get(
-                    function_name, ""
-                ),
+                "OPERATOR": operator_name,
+                "VERSION": operator.version,
                 "TYPE": collection.type.value,
             }
             if parameters.show_details:
                 entry["DESCRIPTION"] = normalize_and_truncate_at_period(
-                    collection.function_operation_descriptions.get(function_name, "")
+                    operator.description or ""
                 )
             entries.append(entry)