Method promptTaskForRequiredCompletionTool

src/node/services/taskService.ts:7406–7526

(
    workspaceId: string,
    options?: {
      reason?: "startup" | "stream_end" | "error";
      error?: Pick<ErrorEvent, "error" | "errorType">;
    }
  )

  }

  private async promptTaskForRequiredCompletionTool(
    workspaceId: string,
    options?: {
      reason?: "startup" | "stream_end" | "error";
      error?: Pick<ErrorEvent, "error" | "errorType">;
    }
  ): Promise<boolean> {
    assert(
      workspaceId.length > 0,
      "promptTaskForRequiredCompletionTool: workspaceId must be non-empty"
    );

    const cfg = this.config.loadConfigOrDefault();
    const entry = findWorkspaceEntry(cfg, workspaceId);
    if (!entry?.workspace.parentWorkspaceId) {
      return false;
    }
    if (entry.workspace.taskStatus !== "awaiting_report") {
      return false;
    }
    const taskIndex = this.buildAgentTaskIndex(cfg);
    if (
      await this.interruptTaskRecoveryForInactiveWorkflowOwner(
        workspaceId,
        cfg,
        `completion-tool-${options?.reason ?? "unknown"}`,
        taskIndex
      )
    ) {
      return false;
    }
    if (await this.hasActiveTaskOwnedWork(workspaceId, taskIndex)) {
      return false;
    }
    if (this.aiService.isStreaming(workspaceId)) {
      return true;
    }

    const isPlanLike = await this.isPlanLikeTaskWorkspace(entry);
    const completionToolName = isPlanLike ? "propose_plan" : "agent_report";

    // Persisted circuit breaker: a task that keeps consuming recovery prompts
    // without ever completing is stuck (repeated empty output, repeated
    // length-truncated turns, or a model that never calls its completion
    // tool). Interrupt it with a descriptive error instead of prompting
    // forever. The counter lives on the workspace entry so restart loops stay
    // bounded too; finalizeAgentTaskReport clears it on success.
    const recoveryAttempts = entry.workspace.taskRecoveryAttempts ?? 0;
    if (recoveryAttempts >= MAX_TASK_RECOVERY_ATTEMPTS) {
      const lastError = options?.error
        ? ` Last error (${options.error.errorType ?? "unknown"}): ${options.error.error}`
        : "";
      log.error("Task exceeded its recovery attempt budget; interrupting task", {
        workspaceId,
        taskName: entry.workspace.name,
        recoveryAttempts,
        limit: MAX_TASK_RECOVERY_ATTEMPTS,
        reason: options?.reason,