Fixed incorrect opctl command help information.

Author: lu-ohai

ads/opctl/backend/ads_dataflow.py

@@ -189,9 +189,10 @@ def watch(self):
         Watch DataFlow Run from OCID.
         """
         run_id = self.config["execution"]["run_id"]
+        interval = self.config["execution"]["interval"]
         with AuthContext(auth=self.auth_type, profile=self.profile):
             run = DataFlowRun.from_ocid(run_id)
-            run.watch()
+            run.watch(interval=interval)
 
 
 class DataFlowRuntimeFactory(RuntimeFactory):

ads/opctl/backend/ads_ml_job.py

@@ -227,10 +227,11 @@ def watch(self):
         Watch Job Run from OCID.
         """
         run_id = self.config["execution"]["run_id"]
-
+        interval = self.config["execution"]["interval"]
+        wait = self.config["execution"]["wait"]
         with AuthContext(auth=self.auth_type, profile=self.profile):
             run = DataScienceJobRun.from_ocid(run_id)
-            run.watch()
+            run.watch(interval=interval, wait=wait)
 
     def _jinja_write(self, operator_slug, operator_folder):
         # TODO AH: fill in templates with relevant details

ads/opctl/backend/ads_ml_pipeline.py

@@ -90,9 +90,13 @@ def watch(self) -> None:
         Watch Pipeline Run from OCID.
         """
         run_id = self.config["execution"]["run_id"]
-        log_type = self.config["execution"].get("log_type")
+        log_type = self.config["execution"]["log_type"]
+        interval = self.config["execution"]["interval"]
         with AuthContext(auth=self.auth_type, profile=self.profile):
-            PipelineRun.from_ocid(run_id).watch(log_type=log_type)
+            PipelineRun.from_ocid(run_id).watch(
+                interval=interval,
+                log_type=log_type
+            )
 
     def init(
         self,

ads/opctl/cli.py

@@ -233,42 +233,29 @@ def init_vscode(**kwargs):
         type=click.Choice(["api_key", "resource_principal"]),
         default=None,
     ),
+]
+
+_model_deployment_options = [
     click.option(
         "--wait-for-completion",
-        help="either to wait for process to complete or not",
+        help="either to wait for process to complete or not for model deployment",
         is_flag=True,
         required=False,
     ),
     click.option(
         "--max-wait-time",
-        help="maximum wait time in seconds for progress to complete",
+        help="maximum wait time in seconds for progress to complete for model deployment",
         type=int,
         required=False,
         default=1200,
     ),
     click.option(
         "--poll-interval",
-        help="poll interval in seconds",
+        help="poll interval in seconds for model deployment",
         type=int,
         required=False,
         default=10,
     ),
-    click.option(
-        "--log-type", help="the type of logging.", required=False, default=None
-    ),
-    click.option(
-        "--log-filter",
-        help="expression for filtering the logs.",
-        required=False,
-        default=None,
-    ),
-    click.option(
-        "--interval",
-        help="log interval in seconds",
-        type=int,
-        required=False,
-        default=3,
-    ),
 ]
 
 
@@ -464,21 +451,46 @@ def init_operator(**kwargs):
 
 @commands.command()
 @click.argument("ocid", nargs=1)
-@add_options(_options)
+@add_options(_model_deployment_options)
 def delete(**kwargs):
     suppress_traceback(kwargs["debug"])(delete_cmd)(**kwargs)
 
 
 @commands.command()
 @click.argument("ocid", nargs=1)
-@add_options(_options)
+@add_options(_model_deployment_options)
 def cancel(**kwargs):
     suppress_traceback(kwargs["debug"])(cancel_cmd)(**kwargs)
 
 
 @commands.command()
 @click.argument("ocid", nargs=1)
-@add_options(_options)
+@click.option(
+    "--log-type", 
+    help="the type of logging. Allowed value: `custom_log` and `service_log` for pipeline, `access` and `predict` for model deployment.", 
+    required=False, 
+    default=None
+)
+@click.option(
+    "--log-filter",
+    help="expression for filtering the logs for model deployment.",
+    required=False,
+    default=None,
+)
+@click.option(
+    "--interval",
+    help="log interval in seconds",
+    type=int,
+    required=False,
+    default=3,
+)
+@click.option(
+    "--wait",
+    help="time in seconds to keep updating the logs after the job run finished for job.",
+    type=int,
+    required=False,
+    default=90
+)
 def watch(**kwargs):
     """
     ``tail`` logs form a job run, dataflow run or pipeline run.
@@ -489,7 +501,7 @@ def watch(**kwargs):
 
 @commands.command()
 @click.argument("ocid", nargs=1)
-@add_options(_options)
+@add_options(_model_deployment_options)
 def activate(**kwargs):
     """
     Activates a data science service.
@@ -499,7 +511,7 @@ def activate(**kwargs):
 
 @commands.command()
 @click.argument("ocid", nargs=1)
-@add_options(_options)
+@add_options(_model_deployment_options)
 def deactivate(**kwargs):
     """
     Deactivates a data science service.