Function executeRemoteQueuedTask

apps/cli/src/commands/daemon.ts:807–912

(
  client: HttpDaemonClient,
  runtime: AgentRuntimeRecord,
  task: QueuedTaskRecord,
)

}

async function executeRemoteQueuedTask(
  client: HttpDaemonClient,
  runtime: AgentRuntimeRecord,
  task: QueuedTaskRecord,
): Promise<void> {
  const payload = parseTaskPayload(task);
  const channelThreadId = resolveConversationThreadId({
    triggerType: task.triggerType,
    payload,
  });
  const workDir = channelThreadId
    ? getDaemonChannelWorkDirPath(ensureDaemonStateDir(), {
      workspaceId: task.workspaceId,
      threadId: channelThreadId,
      agentId: task.agentId,
    })
    : getWorkspaceRemoteTaskWorkDir(task.workspaceId, task.id);
  const isPersistentConversationWorkspace = Boolean(channelThreadId);
  if (!isPersistentConversationWorkspace) {
    rmSync(workDir, { recursive: true, force: true });
  }
  mkdirSync(workDir, { recursive: true });

  try {
    await client.startTask(task.id);
    const bundle = await client.getInputBundle(task.id);
    materializeInputBundle(workDir, bundle);

    const result = await runProviderTask(
      runtime,
      bundle.prompt,
      workDir,
      {
        sessionId: (bundle.metadata.routerSession?.providerSessionId ?? payload.channelSessionId?.trim()) || undefined,
        contextEnv: buildRuntimeContextEnv({
          AGENT_SPACE_CONTEXT_AGENT_NAME: payload.assignee ?? task.agentId,
          AGENT_SPACE_CONTEXT_TASK_ID: task.id,
          AGENT_SPACE_CONTEXT_TRIGGER_TYPE: task.triggerType,
        }, bundle.metadata.googleWorkspace),
        runtimeToolCapabilities: bundle.metadata.runtimeToolCapabilities?.capabilities ?? [],
        onEvent: (event) => {
          void client.reportMessages(task.id, {
            messages: [
              {
                type: event.type,
              content: event.content,
              tool: event.tool,
              inputJson: event.inputJson,
              output: event.output,
            },
          ],
            }).catch((error) => {
              const message = error instanceof Error ? error.message : String(error);
              console.error(`Failed to report remote task message for ${task.id}: ${message}`);
            });
        },
      },
    );