@kyro/batch

new BatchJudge(
  provider: AIProvider,
  configPath: string,
  options?: BatchOptions
)

interface BatchOptions {
  stateDir?: string;      // Directory for state files (default: .kyro/)
  webhookUrl?: string;    // Webhook URL for completion notification
}

async submit(
  transcripts: Array<string | Record<string, unknown>>,
  options?: SubmitOptions
): Promise<BatchJob>

interface SubmitOptions {
  runs?: number;                        // Runs per transcript (default: 1)
  aggregation?: 'majority_vote' | 'any_pass' | 'all_pass';
}
 
interface BatchJob {
  jobId: string;
  submittedAt: Date;
  transcriptCount: number;
  estimatedCompletionMs?: number;
}

async check(jobId?: string): Promise<BatchRunResult | null>

interface BatchRunResult {
  jobId: string;
  status: 'completed' | 'failed';
  total: number;
  passed: number;
  failed: number;
  completedAt: Date;
  results: Array<{
    transcriptIndex: number;
    status: 'SUCCESS' | 'ERROR';
    data: Record<string, StepResult>;
    aggregatedFrom?: number;  // Number of runs aggregated
  }>;
}