Method markWorkflowRunEnded

src/node/services/taskService.ts:3793–3812

Best-effort final recheck for any completed workflow children still deferred by cleanup gates.

(workflowRunId: string)

  /** Best-effort final recheck for any completed workflow children still deferred by cleanup gates. */
  async markWorkflowRunEnded(workflowRunId: string): Promise<void> {
    assert(workflowRunId.length > 0, "markWorkflowRunEnded: workflowRunId must be non-empty");

    const cfg = this.config.loadConfigOrDefault();
    const completedTaskIds: string[] = [];
    for (const project of cfg.projects.values()) {
      for (const workspace of project.workspaces) {
        if (
          workspace.id &&
          workspace.workflowTask?.runId === workflowRunId &&
          hasCompletedAgentReport(workspace)
        ) {
          completedTaskIds.push(workspace.id);
        }
      }
    }
    for (const taskId of completedTaskIds) {
      await this.cleanupReportedLeafTask(taskId);
    }
  }

  /**
   * Interrupt all descendant agent tasks for a workspace (leaf-first).