Function createTaskListTool

src/node/services/tools/task_list.ts:206–338

(config: ToolConfiguration)

}

export const createTaskListTool: ToolFactory = (config: ToolConfiguration) => {
  return tool({
    description: TOOL_DEFINITIONS.task_list.description,
    inputSchema: TOOL_DEFINITIONS.task_list.schema,
    execute: async (args): Promise<unknown> => {
      const workspaceId = requireWorkspaceId(config, "task_list");
      const taskService = requireTaskService(config, "task_list");

      const statuses =
        args.statuses && args.statuses.length > 0 ? args.statuses : [...DEFAULT_STATUSES];
      const includeArchived = args.includeArchived ?? false;
      const archiveLookup = includeArchived
        ? null
        : createWorkspaceArchiveLookup(config, workspaceId);
      const agentStatuses = statuses.filter(isAgentTaskStatus);

      const allAgentTasks =
        agentStatuses.length > 0
          ? taskService.listDescendantAgentTasks(workspaceId, {
              statuses: agentStatuses,
              excludeWorkflowTasks: true,
            })
          : [];
      const agentTasks = allAgentTasks.filter(
        (task) => !shouldHideArchivedAgentTask(task, archiveLookup)
      );
      const tasks: TaskListToolSuccessResult["tasks"] = [...agentTasks];

      // Workflow runs are workspace-scoped (not parent/child workspaces), so they surface as
      // depth-1 entries. interrupted/failed runs stay listable here because they are the
      // resumable ones (workflow_resume).
      if (config.workflowService?.listRuns != null) {
        const runs = await config.workflowService.listRuns({ workspaceId });
        for (const rawRun of runs) {
          const parsed = WorkflowRunRecordSchema.safeParse(rawRun);
          if (
            !parsed.success ||
            !statuses.includes(parsed.data.status) ||
            isNestedWorkflowRun(parsed.data)
          ) {
            continue;
          }
          const workflowProgress = buildWorkflowProgressSummary(parsed.data);
          tasks.push({
            taskId: parsed.data.id,
            status: parsed.data.status,
            parentWorkspaceId: workspaceId,
            title: parsed.data.workflow.name,
            createdAt: parsed.data.createdAt,
            ...(workflowProgress != null ? { workflowProgress } : {}),
            depth: 1,
          });
        }
      }

      const workspaceTurnStatuses = statuses.filter(
        (
          status