export type CancellablePipelineJob = Readonly<{ data?: Readonly<{ ownerId?: string; }>; getState(): Promise; remove(): Promise; }>; export type AccountPipelineQueue = Readonly<{ getJobs(states?: string[]): Promise; }>; export type AccountPipelineCancellationDependencies = Readonly<{ /** Atomically changes every non-terminal run owned by the actor to cancelled. */ cancelRuns(actorUserId: string, signal?: AbortSignal): Promise; queues: readonly AccountPipelineQueue[]; }>; /** * Fence active work durably, then remove only queue entries whose payload has * exact actor ownership metadata. BullMQ active jobs cannot be removed safely; * workers observe the durable fence before every write instead. */ export declare function cancelAccountPipelineJobs(actorUserId: string, deps: AccountPipelineCancellationDependencies, signal?: AbortSignal): Promise;