chore: Feature Store - Fixed a bug in the create_feature_monitor_job function

PiperOrigin-RevId: 704458748

Author: vertex-sdk-bot

tests/unit/vertexai/test_feature_monitor.py

@@ -84,10 +84,8 @@ def create_feature_monitor_job_mock():
         FeatureRegistryServiceClient,
         "create_feature_monitor_job",
     ) as create_feature_monitor_job_mock:
-        create_feature_monitor_job_lro_mock = mock.Mock(ga_operation.Operation)
-        create_feature_monitor_job_lro_mock.result.return_value = _TEST_FG1_FMJ1
         create_feature_monitor_job_mock.return_value = (
-            create_feature_monitor_job_lro_mock
+            _TEST_FG1_FMJ1
         )
         yield create_feature_monitor_job_mock
 
@@ -299,27 +297,6 @@ def test_create_feature_monitor_job(
         labels=_TEST_FG1_FMJ1_LABELS,
     )
 
-    fm_logger_mock.assert_has_calls(
-        [
-            call("Creating FeatureMonitorJob"),
-            call(
-                f"Create FeatureMonitorJob backing LRO:"
-                f" {create_feature_monitor_job_mock.return_value.operation.name}"
-            ),
-            call(
-                "FeatureMonitorJob created. Resource name:"
-                " projects/test-project/locations/us-central1/featureGroups/"
-                "my_fg1/featureMonitors/my_fg1_fm1/featureMonitorJobs/1234567890"
-            ),
-            call("To use this FeatureMonitorJob in another session:"),
-            call(
-                "feature_monitor_job = aiplatform.FeatureMonitorJob("
-                "'projects/test-project/locations/us-central1/featureGroups/"
-                "my_fg1/featureMonitors/my_fg1_fm1/featureMonitorJobs/1234567890')"
-            ),
-        ]
-    )
-
 
 def test_get_feature_monitor_job(
     get_feature_monitor_mock, get_feature_monitor_job_mock

vertexai/resources/preview/feature_store/feature_monitor.py

@@ -36,7 +36,7 @@ class FeatureMonitor(base.VertexAiResourceNounWithFutureManager):
     _resource_noun = "feature_monitors"
     _getter_method = "get_feature_monitor"
     _list_method = "list_feature_monitors"
-    _delete_method = "delete_feature_monitors"
+    _delete_method = "delete_feature_monitor"
     _parse_resource_name_method = "parse_feature_monitor_path"
     _format_resource_name_method = "feature_monitor_path"
     _gca_resource: gca_feature_monitor.FeatureMonitor
@@ -250,7 +250,7 @@ def create_feature_monitor_job(
             location=location, credentials=credentials
         )
 
-        create_feature_monitor_job_lro = api_client.select_version(
+        created_feature_monitor_job = api_client.select_version(
             "v1beta1"
         ).create_feature_monitor_job(
             parent=self.resource_name,
@@ -259,16 +259,6 @@ def create_feature_monitor_job(
             timeout=create_request_timeout,
         )
 
-        _LOGGER.log_create_with_lro(
-            self.FeatureMonitorJob, create_feature_monitor_job_lro
-        )
-
-        created_feature_monitor_job = create_feature_monitor_job_lro.result()
-
-        _LOGGER.log_create_complete(
-            self.FeatureMonitorJob, created_feature_monitor_job, "feature_monitor_job"
-        )
-
         feature_monitor_job_obj = self.FeatureMonitorJob(
             name=created_feature_monitor_job.name,
             project=project,