Add nu CLI interface (#174)

Adds an executable CLI interface `nu`. Explore with `nu install-completion` or `nu --help`. For system-wide functionality install with `pipx`.

Author: gatli

CHANGELOG.md

@@ -4,6 +4,11 @@ All notable changes to the [Nucleus Python Client](https://github.com/scaleapi/n
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.6.0](https://github.com/scaleapi/nucleus-python-client/releases/tag/v0.6.0) - 2021-01-11
+
+### Added
+- Nucleus CLI interface `nu`. Installation instructions are in the `README.md`.
+
 ## [0.5.4](https://github.com/scaleapi/nucleus-python-client/releases/tag/v0.5.4) - 2022-01-28
 
 ### Added

README.md

@@ -17,6 +17,29 @@ Nucleus is a new way—the right way—to develop ML models, helping us move awa
 
 `$ pip install scale-nucleus`
 
+
+## CLI installation
+We recommend installing the CLI via `pipx` (https://pypa.github.io/pipx/installation/). This makes sure that
+the CLI does not interfere with you system packages and is accessible from your favorite terminal.
+
+For MacOS:
+```bash
+brew install pipx
+pipx ensurepath
+pipx install scale-nucleus
+# Optional installation of shell completion (for bash, zsh or fish)
+nu install-completions
+```
+
+Otherwise, install via pip (requires pip 19.0 or later):
+```bash
+python3 -m pip install --user pipx
+python3 -m pipx ensurepath
+python3 -m pipx install scale-nucleus
+# Optional installation of shell completion (for bash, zsh or fish)
+nu install-completions
+```
+
 ## Common issues/FAQ
 
 ### Outdated Client

cli/client.py

@@ -0,0 +1,14 @@
+import functools
+import os
+
+import nucleus
+
+
+@functools.lru_cache()
+def init_client():
+    api_key = os.environ.get("NUCLEUS_API_KEY", None)
+    if api_key:
+        client = nucleus.NucleusClient(api_key)
+    else:
+        raise RuntimeError("No NUCLEUS_API_KEY set")
+    return client

cli/datasets.py

@@ -0,0 +1,77 @@
+import click
+from rich.console import Console
+from rich.table import Column, Table
+
+from cli.client import init_client
+from cli.helpers.nucleus_url import nucleus_url
+from cli.helpers.web_helper import launch_web_or_invoke
+
+
+@click.group("datasets", invoke_without_command=True)
+@click.option("--web", is_flag=True, help="Launch browser")
+@click.pass_context
+def datasets(ctx, web):
+    """Datasets are the base collections of items in Nucleus
+
+    https://dashboard.scale.com/nucleus/datasets
+    """
+    launch_web_or_invoke(
+        sub_url="datasets", ctx=ctx, launch_browser=web, command=list_datasets
+    )
+
+
+@datasets.command("list")
+@click.option(
+    "-m", "--machine-readable", is_flag=True, help="Removes pretty printing"
+)
+def list_datasets(machine_readable):
+    """List all available Datasets"""
+    console = Console()
+    with console.status("Finding your Datasets!", spinner="dots4"):
+        client = init_client()
+        all_datasets = client.datasets
+        if machine_readable:
+            table_params = {"box": None, "pad_edge": False}
+        else:
+            table_params = {
+                "title": ":fire: Datasets",
+                "title_justify": "left",
+            }
+
+        table = Table(
+            "id", "Name", Column("url", overflow="fold"), **table_params
+        )
+        for ds in all_datasets:
+            table.add_row(ds.id, ds.name, nucleus_url(ds.id))
+    console.print(table)
+
+
+@datasets.command("delete")
+@click.option("--id", prompt=True)
+@click.option(
+    "--no-confirm-deletion",
+    is_flag=True,
+    help="WARNING: No confirmation for deletion",
+)
+@click.pass_context
+def delete_dataset(ctx, id, no_confirm_deletion):
+    """Delete a Dataset"""
+    console = Console()
+    client = init_client()
+    id = id.strip()
+    dataset = client.get_dataset(id)
+    delete_string = ""
+    if not no_confirm_deletion:
+        delete_string = click.prompt(
+            click.style(
+                f"Type 'DELETE' to delete dataset: {dataset}", fg="red"
+            )
+        )
+    if no_confirm_deletion or delete_string == "DELETE":
+        client.delete_dataset(dataset.id)
+        console.print(f":fire: :anguished: Deleted {id}")
+    else:
+        console.print(
+            f":rotating_light: Refusing to delete {id}. Received '{delete_string}' instead of 'DELETE'"
+        )
+        ctx.abort()

cli/helpers/__init__.py

@@ -0,0 +1,10 @@
+import os
+from urllib.parse import urljoin
+
+
+def nucleus_url(sub_path: str):
+    nucleus_base = os.environ.get(
+        "NUCLEUS_DASHBOARD", "https://dashboard.scale.com/nucleus/"
+    )
+    extra_params = os.environ.get("NUCLEUS_DASH_PARAMS", "")
+    return urljoin(nucleus_base, sub_path.lstrip("/") + extra_params)

cli/helpers/nucleus_url.py

@@ -0,0 +1,40 @@
+import click
+
+from cli.helpers.nucleus_url import nucleus_url
+
+
+def launch_web_or_show_help(
+    sub_url: str, ctx: click.Context, launch_browser: bool
+):
+    """ Launches the sub_url (composed with nuclues_url(sub_url)) in the browser if requested"""
+    if not ctx.invoked_subcommand:
+        if launch_browser:
+            url = nucleus_url(sub_url)
+            click.launch(url)
+        else:
+            click.echo(ctx.get_help())
+    else:
+        if launch_browser:
+            click.echo(click.style("--web does not work with sub-commands"))
+            ctx.abort()
+
+
+def launch_web_or_invoke(
+    sub_url: str,
+    ctx: click.Context,
+    launch_browser: bool,
+    command: click.BaseCommand,
+):
+    """Launches the sub_url (composed with nuclues_url(sub_url)) in the browser if requested, otherwise invokes
+    the passed command
+    """
+    if not ctx.invoked_subcommand:
+        if launch_browser:
+            url = nucleus_url(sub_url)
+            click.launch(url)
+        else:
+            ctx.invoke(command)
+    else:
+        if launch_browser:
+            click.echo(click.style("--web does not work with sub-commands"))
+            ctx.abort()

cli/helpers/web_helper.py

@@ -0,0 +1,33 @@
+import os
+import shutil
+
+import click
+from shellingham import detect_shell
+
+
+@click.command("install-completion")
+def install_completion():
+    """Install shell completion script to your rc file"""
+    shell, _ = detect_shell()
+    if shell == "zsh":
+        rc_path = "~/.zshrc"
+        append_to_file = 'eval "$(_NU_COMPLETE=zsh_source nu)"'
+    elif shell == "bash":
+        rc_path = "~/.bashrc"
+        append_to_file = 'eval "$(_NU_COMPLETE=bash_source nu)"'
+    elif shell == "fish":
+        rc_path = "~/.config/fish/completions/foo-bar.fish"
+        append_to_file = "eval (env _NU_COMPLETE=fish_source nu)"
+    else:
+        raise RuntimeError(f"Unsupported shell {shell} for completions")
+
+    rc_path_expanded = os.path.expanduser(rc_path)
+    rc_bak = f"{rc_path_expanded}.bak"
+    shutil.copy(rc_path_expanded, rc_bak)
+    click.echo(f"Backed up {rc_path} to {rc_bak}")
+    with open(rc_path_expanded, mode="a") as rc_file:
+        rc_file.write("\n")
+        rc_file.write("# Shell completion for nu\n")
+        rc_file.write(append_to_file)
+    click.echo(f"Completion script added to {rc_path}")
+    click.echo(f"Don't forget to `source {rc_path}")

cli/install_completion.py

@@ -0,0 +1,42 @@
+import click
+from rich.live import Live
+from rich.spinner import Spinner
+from rich.table import Column, Table
+
+from cli.client import init_client
+from cli.helpers.web_helper import launch_web_or_invoke
+
+
+@click.group("jobs", invoke_without_command=True)
+@click.option("--web", is_flag=True, help="Launch browser")
+@click.pass_context
+def jobs(ctx, web):
+    """Jobs are a wrapper around various long-running tasks withing Nucleus
+
+    https://dashboard.scale.com/nucleus/jobs
+    """
+    launch_web_or_invoke("jobs", ctx, web, list_jobs)
+
+
+@jobs.command("list")
+def list_jobs():
+    """List all of your Jobs"""
+    client = init_client()
+    table = Table(
+        Column("id", overflow="fold", min_width=24),
+        "status",
+        "type",
+        "created at",
+        title=":satellite: Jobs",
+        title_justify="left",
+    )
+    with Live(Spinner("dots4", text="Finding your Jobs!")) as live:
+        all_jobs = client.jobs
+        for job in all_jobs:
+            table.add_row(
+                job.job_id,
+                job.job_last_known_status,
+                job.job_type,
+                job.job_creation_time,
+            )
+            live.update(table)

cli/jobs.py

@@ -0,0 +1,35 @@
+import click
+from rich.console import Console
+from rich.table import Column, Table
+
+from cli.client import init_client
+from cli.helpers.nucleus_url import nucleus_url
+from cli.helpers.web_helper import launch_web_or_invoke
+
+
+@click.group("models", invoke_without_command=True)
+@click.option("--web", is_flag=True, help="Launch browser")
+@click.pass_context
+def models(ctx, web):
+    """Models help you store and access your ML model data
+
+    https://dashboard.scale.com/nucleus/models
+    """
+    launch_web_or_invoke("models", ctx, web, list_models)
+
+
+@models.command("list")
+def list_models():
+    """List your Models"""
+    console = Console()
+    with console.status("Finding your Models!", spinner="dots4"):
+        client = init_client()
+        table = Table(
+            Column("id", overflow="fold", min_width=24),
+            "name",
+            Column("url", overflow="fold"),
+        )
+        models = client.models
+        for m in models:
+            table.add_row(m.id, m.name, nucleus_url(m.id))
+    console.print(table)