import type { EffectAction } from "../runtime/types";
import type { JsonRecord } from "../storage/types";
export interface BatchedEffectSummary {
    effectId: string;
    invocationKey: string;
    taskId?: string;
    stepId?: string;
    kind: string;
    label?: string;
    labels?: string[];
    taskDefRef?: string;
    inputsRef?: string;
    requestedAt?: string;
    metadata?: JsonRecord;
    parallelGroupId?: string;
}
export interface ParallelBatch {
    actions: EffectAction[];
    summaries: BatchedEffectSummary[];
}
export interface ParallelPendingPayload {
    effects: BatchedEffectSummary[];
}
export interface BuildParallelBatchOptions {
    maxConcurrency?: number;
    executionStrategy?: 'sequential' | 'concurrent' | 'adaptive';
}
/**
 * Deduplicates EffectAction entries by effectId while preserving order and builds summaries.
 */
export declare function buildParallelBatch(actions: EffectAction[], options?: BuildParallelBatchOptions): ParallelBatch;
export declare function summarizeEffectAction(action: EffectAction): BatchedEffectSummary;
export declare function toParallelPendingPayload(batch: ParallelBatch): ParallelPendingPayload;
//# sourceMappingURL=batching.d.ts.map