Skip to content
Closed
Changes from 3 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
49 changes: 43 additions & 6 deletions bin/lib/onboard.js
Original file line number Diff line number Diff line change
Expand Up @@ -221,10 +221,10 @@ function getNonInteractiveProvider() {
const providerKey = (process.env.NEMOCLAW_PROVIDER || "").trim().toLowerCase();
if (!providerKey) return null;

const validProviders = new Set(["cloud", "ollama", "vllm", "nim"]);
const validProviders = new Set(["cloud", "ollama", "vllm", "nim", "dynamo"]);
if (!validProviders.has(providerKey)) {
console.error(` Unsupported NEMOCLAW_PROVIDER: ${providerKey}`);
console.error(" Valid values: cloud, ollama, vllm, nim");
console.error(" Valid values: cloud, ollama, vllm, nim, dynamo");
process.exit(1);
}

Expand Down Expand Up @@ -473,6 +473,22 @@ async function setupNim(sandboxName, gpu) {
const vllmRunning = !!runCapture("curl -sf http://localhost:8000/v1/models 2>/dev/null", { ignoreError: true });
const requestedProvider = isNonInteractive() ? getNonInteractiveProvider() : null;
const requestedModel = isNonInteractive() ? getNonInteractiveModel(requestedProvider || "cloud") : null;

// Non-interactive Dynamo provider: handle before the interactive options flow
if (isNonInteractive() && requestedProvider === "dynamo") {
const dynamoEndpoint = (process.env.NEMOCLAW_DYNAMO_ENDPOINT || "").trim();
if (!dynamoEndpoint) {
console.error(" NEMOCLAW_DYNAMO_ENDPOINT is required when NEMOCLAW_PROVIDER=dynamo.");
process.exit(1);
}
console.log(` [non-interactive] Using Dynamo provider`);

provider = "dynamo";
model = (process.env.NEMOCLAW_DYNAMO_MODEL || "").trim() || "dynamo";
registry.updateSandbox(sandboxName, { model, provider, nimContainer });
return { model, provider, dynamoEndpoint };
}

// Build options list — only show local options with NEMOCLAW_EXPERIMENTAL=1
const options = [];
if (EXPERIMENTAL && gpu && gpu.nimCapable) {
Expand Down Expand Up @@ -642,10 +658,30 @@ async function setupNim(sandboxName, gpu) {

// ── Step 5: Inference provider ───────────────────────────────────

async function setupInference(sandboxName, model, provider) {
async function setupInference(sandboxName, model, provider, opts = {}) {
step(5, 7, "Setting up inference provider");

if (provider === "nvidia-nim") {
if (provider === "dynamo") {
// Dynamo: external vLLM endpoint (e.g., K8s service)
const dynamoEndpoint = opts.dynamoEndpoint;
if (!dynamoEndpoint) {
console.error(" Dynamo provider requires dynamoEndpoint in options.");
process.exit(1);
}
// Use shellQuote for shell-safe escaping of the endpoint URL
run(
`openshell provider create --name dynamo --type openai ` +
`--credential OPENAI_API_KEY=dummy ` +
`--config OPENAI_BASE_URL=${shellQuote(dynamoEndpoint)} 2>&1 || ` +
`openshell provider update dynamo --credential OPENAI_API_KEY=dummy ` +
`--config OPENAI_BASE_URL=${shellQuote(dynamoEndpoint)} 2>&1 || true`,
{ ignoreError: true }
);
run(
`openshell inference set --no-verify --provider dynamo --model ${shellQuote(model)} 2>/dev/null || true`,
{ ignoreError: true }
);
} else if (provider === "nvidia-nim") {
// Create nvidia-nim provider
run(
`openshell provider create --name nvidia-nim --type openai ` +
Expand Down Expand Up @@ -850,6 +886,7 @@ function printDashboard(sandboxName, model, provider) {
if (provider === "nvidia-nim") providerLabel = "NVIDIA Cloud API";
else if (provider === "vllm-local") providerLabel = "Local vLLM";
else if (provider === "ollama-local") providerLabel = "Local Ollama";
else if (provider === "dynamo") providerLabel = "Dynamo vLLM";

console.log("");
console.log(` ${"─".repeat(50)}`);
Expand Down Expand Up @@ -878,8 +915,8 @@ async function onboard(opts = {}) {
const gpu = await preflight();
await startGateway(gpu);
const sandboxName = await createSandbox(gpu);
const { model, provider } = await setupNim(sandboxName, gpu);
await setupInference(sandboxName, model, provider);
const { model, provider, dynamoEndpoint } = await setupNim(sandboxName, gpu);
await setupInference(sandboxName, model, provider, { dynamoEndpoint });
await setupOpenclaw(sandboxName, model, provider);
await setupPolicies(sandboxName);
printDashboard(sandboxName, model, provider);
Expand Down