Function listRuns

worker/scripts/workflow-runner.ts:85–149

(
  client: Client,
  workflowRecordId: string,
  definition: WorkflowDefinition,
  limit: number,
)

}

async function listRuns(
  client: Client,
  workflowRecordId: string,
  definition: WorkflowDefinition,
  limit: number,
): Promise<ListEntry[]> {
  const runs: ListEntry[] = [];
  const maxMatches = Math.max(limit * 3, limit);

  const query = 'WorkflowType = "shipsecWorkflowRun"';

  for await (const info of client.workflow.list({ query, pageSize: 50 })) {
    if (runs.length >= maxMatches) {
      break;
    }

    const handle = client.workflow.getHandle(info.workflowId, info.runId);
    const history = await handle.fetchHistory();
    const events = history.events ?? [];
    const startedEvent = events.find((event) => event.workflowExecutionStartedEventAttributes);

    if (!startedEvent || !startedEvent.workflowExecutionStartedEventAttributes) {
      continue;
    }

    const { workflowExecutionStartedEventAttributes } = startedEvent;
    const payloads = workflowExecutionStartedEventAttributes.input?.payloads ?? [];
    const args = await Promise.all(
      payloads.map((payload) =>
        client.options.loadedDataConverter.payloadConverter.fromPayload(payload),
      ),
    );
    const firstArg = args[0];

    if (
      !firstArg ||
      typeof firstArg !== 'object' ||
      (firstArg as any).workflowId !== workflowRecordId
    ) {
      continue;
    }

    const entry: ListEntry = {
      workflowId: info.workflowId,
      runId: info.runId,
      status: info.status.name,
      startTime: info.startTime.toISOString(),
      closeTime: info.closeTime?.toISOString(),
      inputs: (firstArg as any).inputs as Record<string, unknown>,
    };

    try {
      const result = await handle.result();
      entry.result = result;
    } catch (error) {
      entry.error = error instanceof Error ? error.message : String(error);
    }