Skip to main content

Cluster relay endpoints backed by clio-core and JARVIS-CD.

Project description

clio-relay banner

clio-relay

clio-relay lets a desktop tool submit work to a remote cluster, follow it while it runs, and collect logs, artifacts, progress, and provenance without putting job state in the network tunnel.

It is a piece of the federation layer for clio-agent: a local CLIO experience can delegate work to a remote machine, keep observing it, detach, reconnect, and clean up after itself. The project is also designed for use outside CLIO. Any client that can call the CLI, HTTP API, or MCP tools can use the same relay model.

Version 1.2.16 uses a release-first patch process. A maintainer builds the wheel and source distribution once, attaches those exact bytes and their checksums to a GitHub Release, and publishes the release immediately. Tag regression jobs and the trusted PyPI upload then run asynchronously; they do not hold the maintainer session open or delay continued live testing. A failure is reproduced with a focused test and corrected in the next patch. The ares and homelab names in the current acceptance policy are evidence labels for this release, not product allowlists. Operators can register other clusters without changing relay code.

How It Works

clio-relay has three long-running roles:

  • desktop: submits work and exposes CLI, HTTP, and MCP surfaces for local tools.
  • worker: runs on a configured cluster, leases work, invokes JARVIS-CD, and records results.
  • relay-host: carries bytes for frp deployments. It does not store jobs or queue state.

The durable boundary is clio-core. The filesystem queue in this repository is the development backend for that record contract. Jobs, task timelines, progress, scheduler state, gateway sessions, logs, artifacts, and provenance are recorded there so clients can detach, reconnect, and replay state. JARVIS-CD owns scheduler execution, package behavior, output collection, and provenance. Lease admission uses a crash-replayed aggregate for constant-read capacity checks, while an explicit full audit retains exact canonical and operational index verification for repair and production diagnostics.

Transport is replaceable because it only carries HTTP bytes between endpoints:

  • Relay mode uses frp through a public relay host. It supports WebSocket/TLS for Cloudflare-style HTTPS infrastructure and raw TCP for environments that provide a direct public port.
  • NAT bypass uses frp XTCP to try a direct peer path between desktop and cluster. It is an optimization for lower-latency or higher-volume traffic, with fallback to relay mode and the durable queue.
  • SSH forwarding uses local port forwarding through an existing SSH or VPN path. It is useful for closed environments that do not want a public relay.

Remote agent tasks, remote MCP calls, JARVIS pipelines, and gateway sessions all use the same queue and observation model. The transport can change without changing where state lives.

Install

For normal use, install the released package once as a persistent uv tool. No checkout is required, and every later command reuses the same isolated tool environment and cache.

uv tool install --python 3.12 --no-config clio-relay
clio-relay init
clio-relay install-frp

Add a cluster. The cluster name and agent executable are local configuration.

clio-relay cluster add --name my-cluster --ssh-host my-cluster-login --agent-adapter exec --agent-bin agent
clio-relay cluster bootstrap --cluster my-cluster
clio-relay cluster install-endpoint-service --cluster my-cluster --concurrency 4 --kind-concurrency remote_agent=2 --kind-concurrency mcp_call=1 --start --enable

Submit Work

Submit a JARVIS pipeline:

clio-relay job submit --cluster my-cluster --jarvis-yaml .\pipeline.yaml
clio-relay job watch <job-id> --cluster my-cluster
clio-relay job read-log <job-id> --cluster my-cluster --stream stdout
clio-relay job list-artifacts <job-id> --cluster my-cluster

Expose relay tools to an agent:

clio-relay agent render-mcp-config --output .\clio-relay-agent.config.toml
clio-relay agent run --cluster my-cluster --prompt /path/on/cluster/prompt.md --mcp-config /path/on/cluster/clio-relay-agent.config.toml

Operators can expose selected tools from any cluster-side stdio MCP server through the same local relay MCP. Registration is allowlisted, and schema discovery is an explicit durable job:

uv tool install --python 3.12 --no-config C:\artifacts\science_mcp_kit-1.4.0-py3-none-any.whl
clio-relay remote-mcp register --cluster my-cluster --name science --command science-mcp --allow-tool inspect_dataset --profile user
clio-relay remote-mcp refresh --cluster my-cluster --name science

User-profile federation requires an exact immutable wheel path (or a unique, non-editable console installation whose complete RECORD closure verifies). A mutable install or a package-index spec such as science-mcp-kit==1.4.0 fails closed and is not exposed to agents.

See remote MCP federation for cache, freshness, alias, collision, profile, and live-acceptance semantics.

Observe Remote Agent Work

Remote agents can emit structured task timeline events while they work. This is useful when a UI needs to show discovery and planning before the final answer exists.

clio-relay job tasks <job-id> --cluster my-cluster
clio-relay job record-task-event <task-id> --cluster my-cluster --event-type dataset_found --label dataset --summary "found staged dataset" --path-ref /mnt/common/datasets/example_001
clio-relay job task-events <task-id> --cluster my-cluster --cursor 1

The same contract is available over HTTP at /tasks/{task_id}/events, /tasks/{task_id}/events/sse, and /tasks/{task_id}/events/ws, and through MCP tools relay_record_task_event and relay_watch_task_events.

Manage Gateway Sessions

Long-running remote services should be tracked as durable gateway sessions. A session records the scheduler job, node, logs, published or forwarded endpoint, health metadata, and reconnect hints. Production service runtimes should be launched by a JARVIS package or pipeline, which owns application-specific monitoring and emits structured status/events back to the relay.

clio-relay gateway create --cluster my-cluster --name live-service-example --gateway-json-file .\gateway.json
clio-relay gateway update <session-id> --cluster my-cluster --state ready --node compute-01 --gateway-json-file .\gateway-ready.json
clio-relay gateway get <session-id> --cluster my-cluster
clio-relay gateway close <session-id> --cluster my-cluster

The HTTP API exposes /gateway-sessions, /gateway-sessions/{session_id}, and /gateway-sessions/{session_id}/close. MCP tools expose the same create, read, update, and close operations.

These generic gateway operations manage ordinary endpoint metadata only. They cannot write scheduler identity, relay runtime specifications or ownership intents, connector ownership, or relay owner metadata. Use gateway start-runtime, detach-runtime, and stop-runtime for relay-owned scheduler-backed services.

When JARVIS already owns a live application, agents use the user-profile relay_bind_jarvis_runtime MCP tool instead of supplying a runtime specification. The relay verifies a completed jarvis_get_execution MCP result produced with include_service_runtimes=true, persists its execution, service, scheduler, and dataset identities, starts only the connector path, and returns local connect, health, stream, events, state, and command URLs. Detach and stop retain the scheduler job unless cancellation is explicitly requested and the original binding can be re-verified.

Sandboxed viewers obtain browser-safe URLs only through the internal gateway browser-attach command after verifying that binding. Its one-time, short-lived capability is never stored in normal gateway output; a loopback proxy requires the capability plus exact Origin: null without wildcard CORS. gateway browser-detach revokes it before stopping the proxy. For SLURM-owned loopback services, the cluster connector is pinned to a provider-verified, single-node BatchHost rather than guessing an allocation node.

Choose Transport

For a public relay through Cloudflare or another HTTPS edge, use frp with transport.protocol = "wss":

$env:CLIO_RELAY_FRP_TOKEN = "<shared-frp-token>"
$env:CLIO_RELAY_STCP_SECRET = "<shared-stcp-secret>"
clio-relay cluster add --name my-cluster --ssh-host my-cluster-login --frp-server-addr relay.example.edu
clio-relay relay-host render-frpc-config --cluster my-cluster --local-port 8848
clio-relay relay-host render-frpc-visitor-config --cluster my-cluster --bind-port 8765
clio-relay relay-host test-http-transport --cluster my-cluster --local-bind-port 18765

For closed environments where SSH or VPN already exists, use SSH local forwarding:

clio-relay relay-host test-ssh-transport --cluster my-cluster --local-bind-port 18766 --remote-api-port 8766 --session-id relay-ssh-test

To leave the remote API alive for a desktop detach and later reattach:

clio-relay session start --cluster my-cluster --session-id desktop-session --remote-api-port 8766 --replace
clio-relay session status --cluster my-cluster --session-id desktop-session
clio-relay session detach --cluster my-cluster --session-id desktop-session
clio-relay session teardown --cluster my-cluster --session-id desktop-session

Use session teardown --stop-worker only when the user chooses to clean up the persistent remote worker too. Teardown keeps relay and scheduler jobs running without prompting. Use --cancel-jobs only for an explicit user choice, and add --cancel-scheduler-jobs only when the scheduler allocation should also be canceled. The JSON result identifies verified ownership and any residual resources.

Documentation

Development

uv sync
uv run ruff check --fix
uv run ruff format
uv run pyright
uv run pytest

The tag workflow builds and attests a digest-bound draft candidate. Independent maintainer sealing verifies its digest and live reports before promotion publishes those exact bytes to PyPI. Published-artifact evidence and PyPI digests must then pass before final verification publishes the GitHub release.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

clio_relay-1.2.16.tar.gz (1.2 MB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

clio_relay-1.2.16-py3-none-any.whl (800.9 kB view details)

Uploaded Python 3

File details

Details for the file clio_relay-1.2.16.tar.gz.

File metadata

  • Download URL: clio_relay-1.2.16.tar.gz
  • Upload date:
  • Size: 1.2 MB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.13.13

File hashes

Hashes for clio_relay-1.2.16.tar.gz
Algorithm Hash digest
SHA256 ff94eb77d0fafc78e4dec4d7d5e6e996f6fbe18c8d10cefd9a2da8775e0df9e3
MD5 f6e6b777b504a06f73446fda0cf9150c
BLAKE2b-256 c3d9e2429f4f39014931ada0a641ac7a34546e6157433fad476d3294adec8764

See more details on using hashes here.

Provenance

The following attestation bundles were made for clio_relay-1.2.16.tar.gz:

Publisher: release.yml on iowarp/clio-relay

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file clio_relay-1.2.16-py3-none-any.whl.

File metadata

  • Download URL: clio_relay-1.2.16-py3-none-any.whl
  • Upload date:
  • Size: 800.9 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.13.13

File hashes

Hashes for clio_relay-1.2.16-py3-none-any.whl
Algorithm Hash digest
SHA256 eced9366b577448b00e74deab2b93040db4d50ca5f4005c3cc9f669fc968b029
MD5 5c5ea0627245853f707140815060ae5c
BLAKE2b-256 2b612ad5b212c17b413245c299021c2ea2579197f500e461b71a1205a7e42711

See more details on using hashes here.

Provenance

The following attestation bundles were made for clio_relay-1.2.16-py3-none-any.whl:

Publisher: release.yml on iowarp/clio-relay

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page