Interface IJobDefinition<DATA>

interface IJobDefinition<DATA = unknown> {
    concurrency?: number;
    filePath: undefined | string;
    fn: DefinitionProcessor<DATA, void | (error?: Error) => void>;
    lockLifetime: number;
    lockLimit: number;
    priority?: number;
}

Type Parameters

  • DATA = unknown

Properties

concurrency?: number

how many jobs of this kind can run in parallel/simultanously per Agenda instance

filePath: undefined | string
fn: DefinitionProcessor<DATA, void | (error?: Error) => void>
lockLifetime: number

lock lifetime in milliseconds

lockLimit: number

max number of locked jobs of this kind

priority?: number

Higher priority jobs will run first.