Skip to main content

commands.ray

Ray commands for Datalayer CLI.

ray_callback​

@app.callback()
def ray_callback(ctx: typer.Context) -> None

Ray management commands.

clusters_callback​

@clusters_app.callback()
def clusters_callback(ctx: typer.Context) -> None

Ray cluster commands.

jobs_callback​

@jobs_app.callback()
def jobs_callback(ctx: typer.Context) -> None

Ray job commands.

jobs_monitor​

@jobs_app.command(name="monitor")
def jobs_monitor(name: str = typer.Argument(..., help="RayJob name."),
                 namespace: str = typer.Option("default",
                                               "--namespace",
                                               help="Kubernetes namespace."),
                 interval_seconds: int = typer.Option(
                     5,
                     "--interval-seconds",
                     min=1,
                     help="Polling interval in seconds."),
                 timeout_seconds: int = typer.Option(
                     600,
                     "--timeout-seconds",
                     min=1,
                     help="Maximum time to wait before exiting."),
                 show_events: bool = typer.Option(
                     False,
                     "--show-events",
                     help="Show latest events on each poll."),
                 token: Optional[str] = typer.Option(None,
                                                     "--api-key",
                                                     help="API key.")) -> None

Monitor RayJob status until it reaches a terminal state.