diff --git a/iii/multi-worker-orchestration/workers/client/src/worker.ts b/iii/multi-worker-orchestration/workers/client/src/worker.ts index 5fab3b5..0a54e5a 100644 --- a/iii/multi-worker-orchestration/workers/client/src/worker.ts +++ b/iii/multi-worker-orchestration/workers/client/src/worker.ts @@ -3,7 +3,9 @@ import { registerWorker } from "iii-sdk"; import { Logger } from "@iii-dev/helpers/observability"; -const iii = registerWorker(process.env.III_URL ?? "ws://localhost:49134"); +const iii = registerWorker(process.env.III_URL ?? "ws://localhost:49134", { + workerName: "client", +}); const logger = new Logger(); // All workers behave as a single application — scoped state set diff --git a/iii/multi-worker-orchestration/workers/compute-worker/src/main.rs b/iii/multi-worker-orchestration/workers/compute-worker/src/main.rs index 3e4363e..033137e 100644 --- a/iii/multi-worker-orchestration/workers/compute-worker/src/main.rs +++ b/iii/multi-worker-orchestration/workers/compute-worker/src/main.rs @@ -1,4 +1,5 @@ -use iii_sdk::{register_worker, RegisterFunction}; +use iii_sdk::runtime::WorkerMetadata; +use iii_sdk::{register_worker, InitOptions, RegisterFunction}; use serde_json::Value; use std::time::Duration; @@ -6,7 +7,16 @@ use std::time::Duration; async fn main() -> Result<(), Box> { let url = std::env::var("III_URL") .unwrap_or_else(|_| "ws://localhost:49134".into()); - let iii = register_worker(&url, Default::default()); + let iii = register_worker( + &url, + InitOptions { + metadata: Some(WorkerMetadata { + name: "compute-worker".into(), + ..Default::default() + }), + ..Default::default() + }, + ); iii.register_function( "compute-worker::compute", diff --git a/iii/multi-worker-orchestration/workers/payment-worker/src/external-worker.ts b/iii/multi-worker-orchestration/workers/payment-worker/src/external-worker.ts index 71f4a1d..1371802 100644 --- a/iii/multi-worker-orchestration/workers/payment-worker/src/external-worker.ts +++ b/iii/multi-worker-orchestration/workers/payment-worker/src/external-worker.ts @@ -2,7 +2,9 @@ // so that other workers connected to iii can trigger them. import { registerWorker } from "iii-sdk"; -const iii = registerWorker(process.env.III_URL ?? "ws://localhost:49134"); +const iii = registerWorker(process.env.III_URL ?? "ws://localhost:49134", { + workerName: "payment-worker", +}); iii.registerFunction("payment-worker::record", async (payload) => { // A real worker would call an external API: diff --git a/iii/quickstart-ai-agents/workers/account-events/src/worker.ts b/iii/quickstart-ai-agents/workers/account-events/src/worker.ts index c8551bc..d6bdd41 100644 --- a/iii/quickstart-ai-agents/workers/account-events/src/worker.ts +++ b/iii/quickstart-ai-agents/workers/account-events/src/worker.ts @@ -7,6 +7,7 @@ import { Logger } from "@iii-dev/helpers/observability"; const iii = registerWorker( process.env.III_BRIDGE_URL ?? "ws://localhost:49134", + { workerName: "account-events" }, ); const logger = new Logger(); diff --git a/iii/quickstart/workers/caller-worker/src/worker.ts b/iii/quickstart/workers/caller-worker/src/worker.ts index ff52d68..880df34 100644 --- a/iii/quickstart/workers/caller-worker/src/worker.ts +++ b/iii/quickstart/workers/caller-worker/src/worker.ts @@ -1,7 +1,9 @@ import { registerWorker } from 'iii-sdk'; import { Logger } from '@iii-dev/helpers/observability'; -const worker = registerWorker(process.env.III_URL ?? 'ws://localhost:49134'); +const worker = registerWorker(process.env.III_URL ?? 'ws://localhost:49134', { + workerName: 'caller-worker', +}); const logger = new Logger(); worker.registerFunction(