Function executeQueuedTask

apps/cli/src/commands/daemon.ts:914–1445

(runtime: AgentRuntimeRecord, queuedTask: QueuedTaskRecord)

}

async function executeQueuedTask(runtime: AgentRuntimeRecord, queuedTask: QueuedTaskRecord): Promise<void> {
  const task = startQueuedTaskSync(queuedTask.id);
  writeWorkspaceStateSync(markChannelDocumentRunStepRunningSync(task.id, task.workspaceId), task.workspaceId);
  const payload = parseTaskPayload(task);

  const budgetCheck = checkAllBudgetsForAgentSync(
    payload.assignee ?? task.agentId,
    payload.channelName ?? payload.channel,
    task.workspaceId,
  );
  if (budgetCheck.status === "exceeded" && budgetCheck.action === "pause") {
    const pct = Math.round(budgetCheck.percentUsed * 100);
    const msg = `Budget exceeded (${pct}% of $${budgetCheck.budget.limitUsd.toFixed(2)}). Task paused.`;
    appendTaskMessageSync({ taskId: task.id, type: "status", content: msg });
    failQueuedTaskSync({ taskId: task.id, errorText: msg });
    if (payload.taskId) updateTaskStatusSync(payload.taskId, "blocked", task.workspaceId);
    return;
  }
  const workspaceState = readWorkspaceStateSync(task.workspaceId);
  const agentProfile = workspaceState.activeEmployees.find((employee: ActiveEmployee) =>
    sameValue(employee.name, payload.assignee ?? task.agentId),
  );
  const compatibleDirectChannelName =
    payload.contactId && !payload.channelName
      ? resolveCompatibleDirectChannelRecord(workspaceState, payload.contactId)?.name
      : undefined;
  const effectiveChannelName = payload.channelName ?? compatibleDirectChannelName;
  const effectivePayload =
    effectiveChannelName && payload.contactId && !payload.channelName
      ? {
          ...payload,
          channelName: effectiveChannelName,
          channelMessage: payload.channelMessage,
        }
      : payload;
  const contactContext =
    payload.contactId ? buildContactAgentContext(workspaceState, payload.contactId) : undefined;
  const channelThreadId =
    resolveConversationThreadId({
      triggerType: task.triggerType,
      payload: {
        channel: payload.channel,
        channelName: effectiveChannelName,
        contactId: payload.contactId,
      },
    });
  appendTaskMessageSync({
    taskId: task.id,
    type: "status",
    content: `Task started on ${runtime.name}.`,
  });

  if (payload.taskId) {
    updateTaskStatusSync(payload.taskId, "in_progress", task.workspaceId);
  }

  const workDir = resolveWorkspaceTaskWorkDir({
    workspaceId: task.workspaceId,