Use default name
This commit is contained in:
parent
861b9bb037
commit
f6dffb81cb
@ -17,7 +17,7 @@ function Batch(name, jobSubscriber, jobQueue, jobRunner, jobService, jobPublishe
|
|||||||
this.jobService = jobService;
|
this.jobService = jobService;
|
||||||
this.jobPublisher = jobPublisher;
|
this.jobPublisher = jobPublisher;
|
||||||
this.logger = logger;
|
this.logger = logger;
|
||||||
this.hostScheduler = new HostScheduler(name, { run: this.processJob.bind(this) }, redisPool);
|
this.hostScheduler = new HostScheduler(this.name, { run: this.processJob.bind(this) }, redisPool);
|
||||||
|
|
||||||
// map: user => jobId. Will be used for draining jobs.
|
// map: user => jobId. Will be used for draining jobs.
|
||||||
this.workInProgressJobs = {};
|
this.workInProgressJobs = {};
|
||||||
|
Loading…
Reference in New Issue
Block a user