From 628ead371bea1bff78ee85ef6974a5b7fee708bf Mon Sep 17 00:00:00 2001 From: nthmost-orkes Date: Sat, 4 Apr 2026 02:53:35 -0700 Subject: [PATCH] fix: JS template uses OrkesClients.from() with optional auth (#15) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - Replace orkesConductorClient (requires keyId/keySecret) with OrkesClients.from() where auth fields are optional - Use Mustache sections so keyId/keySecret are only included when auth_key is configured — OSS users get a clean no-auth client - Switch from TaskManager to TaskHandler (consistent with SDK docs) --- javascript/worker/core/index.js | 52 ++++++++++++++------------------- 1 file changed, 22 insertions(+), 30 deletions(-) diff --git a/javascript/worker/core/index.js b/javascript/worker/core/index.js index d02548e..f209894 100644 --- a/javascript/worker/core/index.js +++ b/javascript/worker/core/index.js @@ -1,39 +1,31 @@ -const { orkesConductorClient } = require("@io-orkes/conductor-javascript"); -const { TaskManager } = require("@io-orkes/conductor-javascript"); -const serverSettings = { +const { OrkesClients, TaskHandler } = require("@io-orkes/conductor-javascript"); + +const config = { + serverUrl: "{{server_url}}", +{{#auth_key}} keyId: "{{auth_key}}", keySecret: "{{auth_secret}}", - serverUrl: "{{server_url}}", +{{/auth_key}} }; -const clientPromise = orkesConductorClient(serverSettings); -async function createTaskManager() { - const client = await clientPromise; - return new TaskManager( - client, - [ +async function main() { + const clients = await OrkesClients.from(config); + + const taskHandler = new TaskHandler(clients, [ { - taskDefName: "{{taskname}}", - execute: async ({ inputData }) => { - - const message ="Hello world" - return { - outputData: { message }, - status: "COMPLETED", - }; + taskDefName: "{{taskname}}", + execute: async (task) => { + const message = "Hello world"; + return { + outputData: { message }, + status: "COMPLETED", + }; + }, }, - } - ], - { - logger: console, - options: { concurrency: 2, pollInterval: 100 }, - } - ); -} + ]); -async function main() { - const taskManager = await createTaskManager(); - taskManager.startPolling(); + taskHandler.startPolling(); + console.log("Worker started, polling for tasks..."); } -main(); \ No newline at end of file +main().catch(console.error);