because reasons

timgit · Mar 9, 2017 · a5ec330 · a5ec330
1 parent 5c8e6a9
commit a5ec330
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/manager.js b/src/manager.js
@@ -102,6 +102,8 @@ class Manager extends EventEmitter {
 
         function register(options, callback) {
 
+            let onError = error => self.emit('error', error);
+
             let workerConfig = {
                 name,
                 fetcher: () => self.fetch(name),
@@ -110,7 +112,7 @@ class Manager extends EventEmitter {
                     self.emit('job', job);
                     setImmediate(() => callback(job, () => self.complete(job.id)));
                 },
-                error: error => self.emit('error', error),
+                error: onError,
                 interval: self.config.newJobCheckInterval
             };