Method initialize

src/node/services/taskService.ts:1833–2148

()

  }

  async initialize(): Promise<void> {
    const startupStartedAt = Date.now();
    const startupConfig = this.config.loadConfigOrDefault();
    const queuedTaskCountAtStartup = this.listAgentTaskWorkspaces(startupConfig).filter(
      (task) => task.taskStatus === "queued" && typeof task.id === "string"
    ).length;

    log.info("[startup] TaskService.initialize starting", {
      queuedTaskCountAtStartup,
    });

    const staleStartingTasks = this.listAgentTaskWorkspaces(startupConfig).filter(
      (task) => task.taskStatus === "starting" && typeof task.id === "string"
    );
    if (staleStartingTasks.length > 0) {
      const recoveries = new Map<
        string,
        { status: Extract<AgentTaskStatus, "queued" | "running">; acceptedPrompt: boolean }
      >();
      for (const task of staleStartingTasks) {
        assert(task.id != null && task.id.length > 0, "stale starting task id is required");
        const isStreaming = this.aiService.isStreaming(task.id);
        recoveries.set(task.id, {
          status: isStreaming ? "running" : "queued",
          acceptedPrompt: !isStreaming && (await this.hasAcceptedInitialTaskPrompt(task.id)),
        });
      }

      await this.config.editConfig((config) => {
        for (const task of staleStartingTasks) {
          assert(task.id != null && task.id.length > 0, "stale starting task id is required");
          const recovery = recoveries.get(task.id);
          assert(recovery != null, "stale starting task recovery is required");
          const entry = findWorkspaceEntry(config, task.id);
          if (!entry) continue;
          entry.workspace.taskStatus = recovery.status;
          if (recovery.acceptedPrompt) {
            // The initial prompt is already durable in chat history; clearing taskPrompt makes the
            // queued recovery path resume that accepted turn instead of appending a duplicate user turn.
            entry.workspace.taskPrompt = undefined;
          }
        }
        return config;
      });
      log.info("[startup] Recovered stale starting agent tasks", {
        count: staleStartingTasks.length,
        acceptedPromptCount: [...recoveries.values()].filter((recovery) => recovery.acceptedPrompt)
          .length,
      });
    }

    const maybeStartQueuedTasksStartedAt = Date.now();
    await this.maybeStartQueuedTasks();
    const maybeStartQueuedTasksMs = Date.now() - maybeStartQueuedTasksStartedAt;

    let config = this.config.loadConfigOrDefault();
    let taskIndex = this.buildAgentTaskIndex(config);
    // Recompute the startup recovery candidate lists from a config snapshot. Hoisted into a