Cleanup.
This commit is contained in:
parent
9c445c1a8c
commit
5aeac61cd1
|
@ -136,7 +136,6 @@ export class InMemoryQueue<T = any> implements Partial<Queue<T>> {
|
||||||
* a JSON message as this is required by Bull.
|
* a JSON message as this is required by Bull.
|
||||||
* @param repeat serves no purpose for the import queue.
|
* @param repeat serves no purpose for the import queue.
|
||||||
*/
|
*/
|
||||||
// add(name: string, data: T, opts?: JobOptions): Promise<Job<T>>;
|
|
||||||
async add(data: T | string, optsOrT?: JobOptions | T) {
|
async add(data: T | string, optsOrT?: JobOptions | T) {
|
||||||
if (typeof data === "string") {
|
if (typeof data === "string") {
|
||||||
throw new Error("doesn't support named jobs")
|
throw new Error("doesn't support named jobs")
|
||||||
|
|
|
@ -201,7 +201,7 @@ class Orchestrator {
|
||||||
return metadata.errorCount
|
return metadata.errorCount
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
err = error
|
err = error
|
||||||
await helpers.wait(Math.random() * 10)
|
await helpers.wait(1000 + Math.random() * 1000)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue