Skip to content

Commit 5f97f22

Browse files
v1r3nv1r3n
committed
fixes
1 parent c1de4cd commit 5f97f22

19 files changed

Lines changed: 61 additions & 52 deletions

‎eslint.config.mjs‎

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,5 +14,17 @@ export default defineConfig(
1414
"docs/**",
1515
"node_modules/**",
1616
],
17+
},
18+
{
19+
rules: {
20+
"@typescript-eslint/no-unused-vars": [
21+
"error",
22+
{
23+
argsIgnorePattern: "^_",
24+
varsIgnorePattern: "^_",
25+
caughtErrorsIgnorePattern: "^_",
26+
},
27+
],
28+
},
1729
}
1830
);

‎examples/advanced/fork-join.ts‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,10 +17,10 @@ import {
1717
simpleTask,
1818
inlineTask,
1919
} from "../../src/sdk";
20-
import type { Task, TaskResult } from "../../src/open-api";
20+
import type { Task } from "../../src/open-api";
2121

2222
// ── Workers for parallel branches ───────────────────────────────────
23-
const fetchUser = worker({ taskDefName: "fj_fetch_user", registerTaskDef: true })(
23+
const _fetchUser = worker({ taskDefName: "fj_fetch_user", registerTaskDef: true })(
2424
async (task: Task) => {
2525
const userId = task.inputData?.userId as string;
2626
return {
@@ -30,7 +30,7 @@ const fetchUser = worker({ taskDefName: "fj_fetch_user", registerTaskDef: true }
3030
}
3131
);
3232

33-
const fetchOrders = worker({ taskDefName: "fj_fetch_orders", registerTaskDef: true })(
33+
const _fetchOrders = worker({ taskDefName: "fj_fetch_orders", registerTaskDef: true })(
3434
async (task: Task) => {
3535
const userId = task.inputData?.userId as string;
3636
// Simulate fetching orders
@@ -48,7 +48,7 @@ const fetchOrders = worker({ taskDefName: "fj_fetch_orders", registerTaskDef: tr
4848
}
4949
);
5050

51-
const fetchPreferences = worker({ taskDefName: "fj_fetch_preferences", registerTaskDef: true })(
51+
const _fetchPreferences = worker({ taskDefName: "fj_fetch_preferences", registerTaskDef: true })(
5252
async (task: Task) => {
5353
const userId = task.inputData?.userId as string;
5454
return {

‎examples/advanced/http-poll.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,9 +17,9 @@ import {
1717
worker,
1818
TaskHandler,
1919
} from "../../src/sdk";
20-
import type { Task, TaskResult } from "../../src/open-api";
20+
import type { Task } from "../../src/open-api";
2121

22-
const processResult = worker({ taskDefName: "hp_process_result", registerTaskDef: true })(
22+
const _processResult = worker({ taskDefName: "hp_process_result", registerTaskDef: true })(
2323
async (task: Task) => {
2424
const pollResult = task.inputData?.pollResult;
2525
return {

‎examples/advanced/sub-workflows.ts‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -17,10 +17,10 @@ import {
1717
simpleTask,
1818
subWorkflowTask,
1919
} from "../../src/sdk";
20-
import type { Task, TaskResult } from "../../src/open-api";
20+
import type { Task } from "../../src/open-api";
2121

2222
// ── Workers ─────────────────────────────────────────────────────────
23-
const validateOrder = worker({ taskDefName: "sw_validate", registerTaskDef: true })(
23+
const _validateOrder = worker({ taskDefName: "sw_validate", registerTaskDef: true })(
2424
async (task: Task) => {
2525
const orderId = task.inputData?.orderId as string;
2626
return {
@@ -30,7 +30,7 @@ const validateOrder = worker({ taskDefName: "sw_validate", registerTaskDef: true
3030
}
3131
);
3232

33-
const chargePayment = worker({ taskDefName: "sw_charge", registerTaskDef: true })(
33+
const _chargePayment = worker({ taskDefName: "sw_charge", registerTaskDef: true })(
3434
async (task: Task) => {
3535
const orderId = task.inputData?.orderId as string;
3636
const amount = (task.inputData?.amount as number) ?? 0;
@@ -46,7 +46,7 @@ const chargePayment = worker({ taskDefName: "sw_charge", registerTaskDef: true }
4646
}
4747
);
4848

49-
const shipOrder = worker({ taskDefName: "sw_ship", registerTaskDef: true })(
49+
const _shipOrder = worker({ taskDefName: "sw_ship", registerTaskDef: true })(
5050
async (task: Task) => {
5151
const orderId = task.inputData?.orderId as string;
5252
return {
@@ -60,7 +60,7 @@ const shipOrder = worker({ taskDefName: "sw_ship", registerTaskDef: true })(
6060
}
6161
);
6262

63-
const notifyCustomer = worker({ taskDefName: "sw_notify", registerTaskDef: true })(
63+
const _notifyCustomer = worker({ taskDefName: "sw_notify", registerTaskDef: true })(
6464
async (task: Task) => {
6565
const orderId = task.inputData?.orderId as string;
6666
const tracking = task.inputData?.trackingNumber as string;

‎examples/advanced/sync-updates.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,9 +18,9 @@ import {
1818
simpleTask,
1919
waitTaskDuration,
2020
} from "../../src/sdk";
21-
import type { Task, TaskResult } from "../../src/open-api";
21+
import type { Task } from "../../src/open-api";
2222

23-
const checkVars = worker({ taskDefName: "su_check_vars", registerTaskDef: true })(
23+
const _checkVars = worker({ taskDefName: "su_check_vars", registerTaskDef: true })(
2424
async (task: Task) => {
2525
return {
2626
status: "COMPLETED",

‎examples/advanced/wait-for-webhook.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,9 +17,9 @@ import {
1717
simpleTask,
1818
waitForWebhookTask,
1919
} from "../../src/sdk";
20-
import type { Task, TaskResult } from "../../src/open-api";
20+
import type { Task } from "../../src/open-api";
2121

22-
const processWebhookPayload = worker({ taskDefName: "wh_process_payload", registerTaskDef: true })(
22+
const _processWebhookPayload = worker({ taskDefName: "wh_process_payload", registerTaskDef: true })(
2323
async (task: Task) => {
2424
const payload = task.inputData?.webhookPayload as Record<string, unknown>;
2525
return {

‎examples/agentic-workflows/function-calling.ts‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,10 @@ import {
2222
inlineTask,
2323
Role,
2424
} from "../../src/sdk";
25-
import type { Task, TaskResult } from "../../src/open-api";
25+
import type { Task } from "../../src/open-api";
2626

2727
// ── Tool workers ────────────────────────────────────────────────────
28-
const getWeather = worker({ taskDefName: "fn_get_weather", registerTaskDef: true })(
28+
const _getWeather = worker({ taskDefName: "fn_get_weather", registerTaskDef: true })(
2929
async (task: Task) => {
3030
const city = (task.inputData?.city as string) ?? "Unknown";
3131
// Simulate weather API
@@ -41,7 +41,7 @@ const getWeather = worker({ taskDefName: "fn_get_weather", registerTaskDef: true
4141
}
4242
);
4343

44-
const getStockPrice = worker({ taskDefName: "fn_get_stock_price", registerTaskDef: true })(
44+
const _getStockPrice = worker({ taskDefName: "fn_get_stock_price", registerTaskDef: true })(
4545
async (task: Task) => {
4646
const symbol = (task.inputData?.symbol as string) ?? "AAPL";
4747
// Simulate stock API
@@ -55,7 +55,7 @@ const getStockPrice = worker({ taskDefName: "fn_get_stock_price", registerTaskDe
5555
}
5656
);
5757

58-
const calculate = worker({ taskDefName: "fn_calculate", registerTaskDef: true })(
58+
const _calculate = worker({ taskDefName: "fn_calculate", registerTaskDef: true })(
5959
async (task: Task) => {
6060
const expression = (task.inputData?.expression as string) ?? "0";
6161
let result: number;

‎examples/api-journeys/schedules.ts‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,6 @@ async function main() {
2121
const clients = await OrkesClients.from();
2222
const scheduler = clients.getSchedulerClient();
2323
const workflowClient = clients.getWorkflowClient();
24-
const client = clients.getClient();
25-
2624
const scheduleName = "journey_example_schedule";
2725
const wfName = "schedule_journey_workflow";
2826

‎examples/dynamic-workflow.ts‎

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,11 @@ import {
1515
simpleTask,
1616
switchTask,
1717
doWhileTask,
18-
inlineTask,
1918
} from "../src/sdk";
2019
import type { Task } from "../src/open-api";
2120

2221
// ── Workers ─────────────────────────────────────────────────────────
23-
const fetchData = worker({ taskDefName: "fetch_data", registerTaskDef: true })(
22+
const _fetchData = worker({ taskDefName: "fetch_data", registerTaskDef: true })(
2423
async (task: Task) => {
2524
const source = (task.inputData?.source as string) ?? "default";
2625
return {
@@ -36,7 +35,7 @@ const fetchData = worker({ taskDefName: "fetch_data", registerTaskDef: true })(
3635
}
3736
);
3837

39-
const processRecord = worker({ taskDefName: "process_record", registerTaskDef: true })(
38+
const _processRecord = worker({ taskDefName: "process_record", registerTaskDef: true })(
4039
async (task: Task) => {
4140
const record = task.inputData?.record as Record<string, unknown>;
4241
return {
@@ -50,7 +49,7 @@ const processRecord = worker({ taskDefName: "process_record", registerTaskDef: t
5049
}
5150
);
5251

53-
const sendNotification = worker({ taskDefName: "send_notification", registerTaskDef: true })(
52+
const _sendNotification = worker({ taskDefName: "send_notification", registerTaskDef: true })(
5453
async (task: Task) => {
5554
const channel = (task.inputData?.channel as string) ?? "email";
5655
const message = (task.inputData?.message as string) ?? "";

‎examples/event-listeners.ts‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ class ExecutionLogger implements TaskRunnerEventsListener {
9191

9292
// ── Timing listener (measures execution time) ───────────────────────
9393
class TimingListener implements TaskRunnerEventsListener {
94-
private timings: Array<{ task: string; ms: number }> = [];
94+
private timings: { task: string; ms: number }[] = [];
9595

9696
onTaskExecutionCompleted(event: TaskExecutionCompleted): void {
9797
this.timings.push({ task: event.taskType, ms: event.durationMs });
@@ -111,17 +111,17 @@ class TimingListener implements TaskRunnerEventsListener {
111111
}
112112

113113
// ── Workers ─────────────────────────────────────────────────────────
114-
const fastTask = worker({ taskDefName: "evt_fast_task", registerTaskDef: true })(
115-
async (task: Task) => {
114+
const _fastTask = worker({ taskDefName: "evt_fast_task", registerTaskDef: true })(
115+
async (_task: Task) => {
116116
return {
117117
status: "COMPLETED",
118118
outputData: { fast: true },
119119
};
120120
}
121121
);
122122

123-
const slowTask = worker({ taskDefName: "evt_slow_task", registerTaskDef: true })(
124-
async (task: Task) => {
123+
const _slowTask = worker({ taskDefName: "evt_slow_task", registerTaskDef: true })(
124+
async (_task: Task) => {
125125
// Simulate work
126126
await new Promise((resolve) => setTimeout(resolve, 100));
127127
return {

0 commit comments

Comments
 (0)