Cluster relay endpoints backed by clio-core and JARVIS-CD.
Project description
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.3.27uses 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. Thearesandhomelabnames 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
The enabled worker is an always-on cluster service, not a desktop-session
process. Its installer therefore requires loginctl to report Linger=yes
before it writes or starts the unit. Enable lingering once on the cluster when
site policy permits (loginctl enable-linger "$USER"), or ask the site
administrator to enable it. --allow-login-scoped is an explicit diagnostic
opt-out for sites that forbid lingering; that service may stop after the final
login exits and cannot satisfy release validation.
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
Pin consumed artifacts at submission with repeatable
--used-artifact <artifact-id>=<sha256> arguments. The job then exposes its
immutable inputs with job used-artifacts, while job used-by follows the
reverse edge from an artifact to downstream jobs. The same bidirectional
lineage is available through HTTP and the single agent-facing
relay_artifact_lineage MCP tool.
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. A waited query returns compact
service_runtime_bindings; the agent passes one entry unchanged as
relay_bind_jarvis_runtime.binding instead of guessing opaque job, artifact, or
service identifiers. The relay 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
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file clio_relay-1.3.27.tar.gz.
File metadata
- Download URL: clio_relay-1.3.27.tar.gz
- Upload date:
- Size: 1.3 MB
- Tags: Source
- Uploaded using Trusted Publishing? Yes
- Uploaded via: twine/6.1.0 CPython/3.13.13
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
6bb6ce2ba794a385f33ae94f997fc9278b6d1b22ba5b031fcca6182e958db667
|
|
| MD5 |
3492a5f122da6a6693f018c8728cfdf6
|
|
| BLAKE2b-256 |
da552fe27919afb3eb335f4f6635322c202386cec2daf5fb2b1bb25113f1141c
|
Provenance
The following attestation bundles were made for clio_relay-1.3.27.tar.gz:
Publisher:
release.yml on iowarp/clio-relay
-
Statement:
-
Statement type:
https://in-toto.io/Statement/v1 -
Predicate type:
https://docs.pypi.org/attestations/publish/v1 -
Subject name:
clio_relay-1.3.27.tar.gz -
Subject digest:
6bb6ce2ba794a385f33ae94f997fc9278b6d1b22ba5b031fcca6182e958db667 - Sigstore transparency entry: 2193538040
- Sigstore integration time:
-
Permalink:
iowarp/clio-relay@ee058536a5f75b81a533c84943170a494ff3ed92 -
Branch / Tag:
refs/tags/v1.3.27 - Owner: https://github.com/iowarp
-
Access:
public
-
Token Issuer:
https://token.actions.githubusercontent.com -
Runner Environment:
github-hosted -
Publication workflow:
release.yml@ee058536a5f75b81a533c84943170a494ff3ed92 -
Trigger Event:
push
-
Statement type:
File details
Details for the file clio_relay-1.3.27-py3-none-any.whl.
File metadata
- Download URL: clio_relay-1.3.27-py3-none-any.whl
- Upload date:
- Size: 862.7 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? Yes
- Uploaded via: twine/6.1.0 CPython/3.13.13
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
657f35ba6acccdb4b17b75e39f1387bd4a13746300bcdf769ba2358b0f2bc623
|
|
| MD5 |
f0208338da208105f28bd8f6ee5bd047
|
|
| BLAKE2b-256 |
288e3bdc507f847465cdf7265ff86cc1241a78fb576013b57a1d4abc9a4bbe75
|
Provenance
The following attestation bundles were made for clio_relay-1.3.27-py3-none-any.whl:
Publisher:
release.yml on iowarp/clio-relay
-
Statement:
-
Statement type:
https://in-toto.io/Statement/v1 -
Predicate type:
https://docs.pypi.org/attestations/publish/v1 -
Subject name:
clio_relay-1.3.27-py3-none-any.whl -
Subject digest:
657f35ba6acccdb4b17b75e39f1387bd4a13746300bcdf769ba2358b0f2bc623 - Sigstore transparency entry: 2193538046
- Sigstore integration time:
-
Permalink:
iowarp/clio-relay@ee058536a5f75b81a533c84943170a494ff3ed92 -
Branch / Tag:
refs/tags/v1.3.27 - Owner: https://github.com/iowarp
-
Access:
public
-
Token Issuer:
https://token.actions.githubusercontent.com -
Runner Environment:
github-hosted -
Publication workflow:
release.yml@ee058536a5f75b81a533c84943170a494ff3ed92 -
Trigger Event:
push
-
Statement type: