import { IEventHandler, StepFunctionService } from '@mbc-cqrs-serverless/core';
import { ImportService } from '../import.service';
import { ImportStatusQueueEvent } from './import-status.queue.event';
export declare class ImportStatusHandler implements IEventHandler<ImportStatusQueueEvent> {
    private readonly importService;
    private readonly sfnService;
    private readonly logger;
    constructor(importService: ImportService, sfnService: StepFunctionService);
    execute(event: ImportStatusQueueEvent): Promise<void>;
    /**
     * Merges the import job result with FAILED status for ZIP orchestrator callbacks.
     */
    private buildZipOrchestratorFailureOutput;
    /**
     * Sends a success signal to a waiting Step Function task.
     * @param taskToken The unique token of the paused task.
     * @param output The JSON output to send back to the state machine.
     */
    sendTaskSuccess(taskToken: string, output: any): Promise<import("@aws-sdk/client-sfn").SendTaskSuccessCommandOutput>;
    /**
     * Sends a failure signal to a waiting Step Function task.
     *
     * NOTE: As of this PR, this method is no longer called from execute().
     * The ZIP orchestrator uses SendTaskSuccess with importJobStatus instead (Option B),
     * so the Map state can continue processing remaining files even when one CSV fails.
     * Kept public for potential use cases outside ZIP orchestration.
     *
     * @param taskToken The unique token of the paused task.
     * @param error The error code to send back to the state machine.
     * @param cause The detailed cause of the failure (will be JSON stringified).
     */
    sendTaskFailure(taskToken: string, error: string, cause: any): Promise<import("@aws-sdk/client-sfn").SendTaskFailureCommandOutput>;
}