@taico/worker 0.4.1
“[](https://badge.socket.dev/npm/package/@taico/worker/0.4.1)”
Source contains an unconditional loopWhile loop contains a try block
SHA-256f16d9b55934fffc0eebc4c3ac240203215949236dd7b569d96340706b6f19fa4
MaleculeH(U)
Evidence
1:6… KAgentRunner.ts
2import { BaseAgentRunner } from "./BaseAgentRunner.js";
3import { LlmAgent, Runner, InMemorySessionService, MCPToolset, BaseTool, } from "@google/adk";
4import { ADKMessageFormatter } from "../formatters/ADKMessageFormatter.js";
5import { EXECUTION_ID_HEADER } from "../helpers/config.js";
6import { randomUUID } from "node:crypto";
7import { InterruptedExecutionError } from "../task-execution-errors.js";
8class NamespacedTool extends BaseTool {
9 wrappedTool;
10 namespacedName;
11 constructor …
⋯4 lines
71 });
72 await setSession(session.id);
73 const mcpServers = ctx.mcpServers ?? {
74 tasks: {
75 type: 'http',
76 url: `${ctx.baseUrl}/api/v1/tasks/tasks/mcp`,
77 headers: {
78 Authorization: `Bearer ${ctx.accessToken}`,
79 [EXECUTION_ID_HEADER]: ctx.executionId,
80 },
81 },
82 context: {
83 …
61:14… n ensureAuthenticatedWithRetry(auth) {
62 let attempt = 1;
63 while (true) {
64 try {
65 clearRetryStatusLine();
⋯4 lines
85:27… ncel or Ctrl+C to exit.'
86 : 'Press Ctrl+C to exit.';
87 process.stdout.write(`\r\x1b[2K[worker] Taico Server is not responding. Retrying in ${STARTUP_RETRY_DELAY_MS / 1000}s. Failed ${attempt} time${attempt === 1 ? …
94:13… t sleep(delayMs);
95 return false;
96 }
97 const stdin = process.stdin;
98 return new Promise((resolve, reject) => {
99 const timeout = setTimeout(() => {
⋯4 lines
No evidence locations were recorded for this file. Raw result