Method listRuns

src/node/services/workflows/WorkflowRunStore.ts:262–286

()

  }

  async listRuns(): Promise<WorkflowRunRecord[]> {
    let entries: Dirent[];
    try {
      entries = await fs.readdir(this.workflowsDir(), { withFileTypes: true });
    } catch {
      return [];
    }

    const runs = await Promise.all(
      entries
        .filter((entry) => entry.isDirectory())
        .map(async (entry): Promise<WorkflowRunRecord | null> => {
          try {
            return await this.getRun(entry.name);
          } catch (error) {
            log.warn(`Skipping unreadable workflow run '${entry.name}': ${getErrorMessage(error)}`);
            return null;
          }
        })
    );

    return runs
      .filter((run): run is WorkflowRunRecord => run != null)
      .sort((a, b) => a.createdAt.localeCompare(b.createdAt));
  }

  async appendNextEvent(
    runId: string,