fix: scheduling tag retrieval (#59)

artefactory · Oct 5, 2023 · 11347ba · 11347ba
1 parent 0226088
commit 11347ba
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 7 deletions.
diff --git a/deployer/cli.py b/deployer/cli.py
@@ -208,15 +208,15 @@ def deploy(  # noqa: C901
         parameter_values, input_artifacts = load_config(config_filepath)
 
     if compile:
-        with console.status("Compiling pipeline...\n"):
+        with console.status("Compiling pipeline..."):
             deployer.compile()
 
     if upload:
-        with console.status("Uploading pipeline...\n"):
+        with console.status("Uploading pipeline..."):
             deployer.upload_to_registry(tags=tags)
 
     if run:
-        with console.status("Running pipeline...\n"):
+        with console.status("Running pipeline..."):
             deployer.run(
                 enable_caching=enable_caching,
                 parameter_values=parameter_values,
@@ -226,7 +226,7 @@ def deploy(  # noqa: C901
             )
 
     if schedule:
-        with console.status("Scheduling pipeline...\n"):
+        with console.status("Scheduling pipeline..."):
             cron = cron.replace("-", " ")  # ugly fix to allow cron expression as env variable
             deployer.schedule(
                 cron=cron,

diff --git a/deployer/pipeline_deployer.py b/deployer/pipeline_deployer.py
@@ -256,13 +256,14 @@ def schedule(
 
         if tag:
             client = RegistryClient(host=self.gar_host)
+            package_name = self.pipeline_name.replace("_", "-")
             try:
-                tag_metadata = client.get_tag(package_name=self.pipeline_name, tag=tag)
+                tag_metadata = client.get_tag(package_name=package_name, tag=tag)
             except HTTPError as e:
-                tags_list = client.list_tags(self.pipeline_name)
+                tags_list = client.list_tags(package_name)
                 tags_list_parsed = [x["name"].split("/")[-1] for x in tags_list]
                 raise TagNotFoundError(
-                    f"Tag {tag} not found for package {self.gar_host}/{self.pipeline_name}.\
+                    f"Tag {tag} not found for package {self.gar_host}/{package_name}.\
                         Available tags: {tags_list_parsed}"
                 ) from e