Function pollLoop

orchestrate/skills/orchestrate/scripts/core/agent-manager.ts:1864–1925

()

  const waitStartedAt = Date.now();

  const pollLoop = async (): Promise<RunResult> => {
    while (!ac.signal.aborted) {
      try {
        await sleep(WAIT_WATCHDOG_POLL_INTERVAL_MS, undefined, {
          signal: ac.signal,
        });
      } catch {
        return Promise.reject(new Error("watchdog aborted"));
      }
      if (ac.signal.aborted) break;
      let probe: Run;
      try {
        probe = await Agent.getRun(args.runId, {
          runtime: "cloud",
          apiKey: args.apiKey,
          agentId: args.agentId,
        });
      } catch {
        continue;
      }
      if (probe.status !== "running") {
        return probe.wait();
      }
      const idleMs = Date.now() - args.lastSseActivityAt.value;
      if (idleMs >= WAIT_SSE_IDLE_ATTENTION_MS && !idleEpisodeLogged) {
        idleEpisodeLogged = true;
        args.logAttention(
          `${args.taskLabel}: SSE idle ${idleMs}ms, polled status=running; watchdog still waiting`
        );
      }
      if (idleMs >= STUCK_ESCALATION_MS && !sseStuckEpisodeLogged) {
        sseStuckEpisodeLogged = true;
        args.logAttention(`${args.taskLabel}: SSE idle ${idleMs}ms; stuck`);
      }
      const toolCallIdleMs =
        Date.now() - (args.lastToolCallAt.value ?? waitStartedAt);
      if (
        toolCallIdleMs >= WAIT_TOOL_CALL_IDLE_ATTENTION_MS &&
        !toolCallIdleEpisodeLogged
      ) {
        toolCallIdleEpisodeLogged = true;
        args.logAttention(
          formatToolCallIdleWarning({
            taskLabel: args.taskLabel,
            idleMs: toolCallIdleMs,
            lastToolCallAt: args.lastToolCallAt.value,
            waitStartedAt,
          })
        );
      }
      if (
        toolCallIdleMs >= toolCallStuckThresholdMs() &&
        !toolCallStuckEpisodeLogged
      ) {
        toolCallStuckEpisodeLogged = true;
        args.logAttention(
          `${args.taskLabel}: tool_call idle ${toolCallIdleMs}ms; stuck`
        );