Skip to content

Commit

Permalink
fix: remove internal deps on barrel fixes #469 (#495)
Browse files Browse the repository at this point in the history
  • Loading branch information
manast authored Apr 23, 2021
1 parent 3b7c038 commit 60dbeed
Show file tree
Hide file tree
Showing 7 changed files with 17 additions and 9 deletions.
2 changes: 1 addition & 1 deletion src/classes/child-pool.ts
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
import { ChildProcess, fork } from 'child_process';
import * as path from 'path';
import { forEach, values, flatten } from 'lodash';
import { values, flatten } from 'lodash';
import * as getPort from 'get-port';
import * as fs from 'fs';
import { promisify } from 'util';
Expand Down
7 changes: 5 additions & 2 deletions src/classes/compat.ts
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,11 @@
// TypeScript Version: 2.8

import { EventEmitter } from 'events';
import { QueueEvents, Worker, Queue, QueueScheduler, Job } from './';
import { Job } from './job';
import { QueueScheduler } from './queue-scheduler';
import { Queue } from './queue';
import { Worker } from './worker';
import { QueueEvents } from './queue-events';
import {
JobsOptions,
QueueOptions,
Expand All @@ -30,7 +34,6 @@ import {
WorkerOptions,
Processor,
} from '../interfaces';
import IORedis = require('ioredis');

type CommonOptions = QueueSchedulerOptions &
QueueOptions &
Expand Down
3 changes: 2 additions & 1 deletion src/classes/job.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,8 @@ import { debuglog } from 'util';
import { RetryErrors } from '../enums';
import { BackoffOptions, JobsOptions, WorkerOptions } from '../interfaces';
import { errorObject, isEmpty, tryCatch } from '../utils';
import { Backoffs, QueueEvents } from './';
import { QueueEvents } from './queue-events';
import { Backoffs } from './backoffs';
import { MinimalQueue, ParentOpts, Scripts } from './scripts';
import { fromPairs } from 'lodash';

Expand Down
2 changes: 1 addition & 1 deletion src/classes/queue-scheduler.ts
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
import { QueueSchedulerOptions } from '../interfaces';
import { array2obj, isRedisInstance } from '../utils';
import { QueueBase } from './';
import { QueueBase } from './queue-base';
import { Scripts } from './scripts';
import { StreamReadRaw } from '../interfaces/redis-streams';
import IORedis = require('ioredis');
Expand Down
5 changes: 3 additions & 2 deletions src/classes/queue.ts
Original file line number Diff line number Diff line change
@@ -1,8 +1,9 @@
import { Parent } from '../interfaces/parent';
import { get } from 'lodash';
import { v4 } from 'uuid';
import { JobsOptions, QueueOptions, RepeatOptions } from '../interfaces';
import { Job, QueueGetters, Repeat } from './';
import { Repeat } from './repeat';
import { QueueGetters } from './queue-getters';
import { Job } from './job';
import { Scripts } from './scripts';

export class Queue<
Expand Down
3 changes: 2 additions & 1 deletion src/classes/repeat.ts
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
import { createHash } from 'crypto';
import { JobsOptions, RepeatOptions } from '../interfaces';
import { Job, QueueBase } from './';
import { QueueBase } from './queue-base';
import { Job } from './job';

const parser = require('cron-parser');

Expand Down
4 changes: 3 additions & 1 deletion src/classes/scripts.ts
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,9 @@ import {
WorkerOptions,
} from '../interfaces';
import { array2obj } from '../utils';
import { QueueBase, QueueScheduler, Worker } from './';
import { Worker } from './worker';
import { QueueScheduler } from './queue-scheduler';
import { QueueBase } from './queue-base';
import { Job, JobJson, JobJsonRaw } from './job';

export type MinimalQueue = Pick<
Expand Down

0 comments on commit 60dbeed

Please sign in to comment.