clean up

Pioreactor · Sep 17, 2024 · 32e95d9 · 32e95d9
1 parent cf95bad
commit 32e95d9
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/pioreactor/cli/pios.py b/pioreactor/cli/pios.py
@@ -212,7 +212,7 @@ def _thread_function(unit: str) -> bool:
             _thread_function(unit)
 
     @pios.command("rm", short_help="rm a file across the cluster")
-    @click.argument("filepath", type=click.Path(exists=True, resolve_path=True))
+    @click.argument("filepath", type=click.Path(resolve_path=True))
     @which_units
     @confirmation
     def rm(
@@ -328,7 +328,7 @@ def _thread_function(unit: str) -> tuple[bool, dict]:
 
         for result, api_result in results:
             click.secho(
-                f'{api_result.get("unit")}: {api_result.get("result_url_path")}',
+                api_result,
                 fg="green" if result else "red",
             )
 
@@ -366,7 +366,7 @@ def install_plugin(plugin: str, source: str | None, units: tuple[str, ...], y: b
             commands["options"] = {"source": source}
 
         def _thread_function(unit: str) -> tuple[bool, dict]:
-            print(f"Installing {plugin} on {unit}")
+            click.echo(f"Installing {plugin} on {unit}")
             try:
                 r = post_into(
                     resolve_to_address(unit), "/unit_api/plugins/install", json=commands, timeout=60
@@ -382,7 +382,7 @@ def _thread_function(unit: str) -> tuple[bool, dict]:
 
         for result, api_result in results:
             click.secho(
-                f'{api_result.get("unit")}: {api_result.get("result_url_path")}',
+                api_result,
                 fg="green" if result else "red",
             )
 
@@ -409,7 +409,7 @@ def uninstall_plugin(plugin: str, units: tuple[str, ...], y: bool) -> None:
                 raise click.Abort()
 
         def _thread_function(unit: str) -> tuple[bool, dict]:
-            print(f"Uninstalling {plugin} on {unit}")
+            click.echo(f"Uninstalling {plugin} on {unit}")
             try:
                 r = post_into(
                     resolve_to_address(unit), "/unit_api/plugins/uninstall", json=commands, timeout=60
@@ -426,7 +426,7 @@ def _thread_function(unit: str) -> tuple[bool, dict]:
 
         for result, api_result in results:
             click.secho(
-                f'{api_result.get("unit")}: {api_result.get("result_url_path")}',
+                api_result,
                 fg="green" if result else "red",
             )