import { AbstractTask } from "@golemio/core/dist/integration-engine/workers";
import { MessageProperties } from "amqplib";
import { ICachedDataset } from "./helpers/HelperTypes";
import { CachedDatasetSchema } from "./schema/CachedDatasetSchema";
export declare class TransformAndSaveDataTask extends AbstractTask<ICachedDataset> {
    readonly queueName = "transformAndSaveData";
    readonly queueTtl: number;
    readonly schema: typeof CachedDatasetSchema;
    private logger;
    private metadataRepository;
    private ropidGtfsFactory;
    private gtfsRedisChannel;
    constructor(queuePrefix: string);
    protected execute(inputData: ICachedDataset, msgProperties?: MessageProperties): Promise<void>;
    private saveTransformedDataset;
    private streamDataToTmp;
    private getTmpModelByName;
}