flow-job.d.ts 800 B

12345678910111213141516171819202122
  1. import { DeduplicationOptions, JobsOptions } from '../types';
  2. import { QueueOptions } from './queue-options';
  3. export interface FlowJobBase<T> {
  4. name: string;
  5. queueName: string;
  6. data?: any;
  7. prefix?: string;
  8. opts?: Omit<T, 'repeat'>;
  9. children?: FlowChildJob[];
  10. }
  11. export type FlowChildJob = FlowJobBase<Omit<JobsOptions, 'debounce' | 'deduplication' | 'parent'>>;
  12. export type FlowJob = FlowJobBase<Omit<JobsOptions, 'debounce' | 'deduplication'> & {
  13. debounce?: Omit<DeduplicationOptions, 'replace'>;
  14. deduplication?: Omit<DeduplicationOptions, 'replace'>;
  15. }>;
  16. export type FlowQueuesOpts = Record<string, Omit<QueueOptions, 'connection' | 'prefix'>>;
  17. export interface FlowOpts {
  18. /**
  19. * Map of options for Queue classes.
  20. */
  21. queuesOptions: FlowQueuesOpts;
  22. }