import { PersisterClient } from 'src/persister';
import { IntegrationJobKey, IntegrationLogger } from '../types';
/**
 * Publishes an `END_JOB_OPERATION` to the persister, status `COMPLETED`.
 *
 * This operation is sent last of all operations to signal to the persister that
 * there will be no more operations for the job, at which point the persister
 * will mark the job as completed.
 */
export declare function publishEndJobOnCompletion(logger: IntegrationLogger, persister: PersisterClient, jobKey: IntegrationJobKey): Promise<void>;
/**
 * Publishes an `END_JOB_OPERATION` to the persister, status `FAILED`.
 *
 * This operation is sent last of all operations to signal to the persister that
 * there will be no more operations for the job, at which point the persister
 * will mark the job as failed.
 */
export declare function publishEndJobOnError(logger: IntegrationLogger, persister: PersisterClient, jobKey: IntegrationJobKey, error: Error): Promise<void>;