From 6ce08acd268ef6a2e00a05ac3b938ba66652601e Mon Sep 17 00:00:00 2001
From: Joe Fleming <joe.fleming@gmail.com>
Date: Wed, 4 May 2016 11:41:49 -0700
Subject: [PATCH] worker functions use promises for async

---
 src/worker.js | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/src/worker.js b/src/worker.js
index 3a38991..fa98c68 100644
--- a/src/worker.js
+++ b/src/worker.js
@@ -118,10 +118,7 @@ export default class Job extends events.EventEmitter {
     this.debug(`Starting job ${job._id}`);
 
     const workerOutput = new Promise((resolve, reject) => {
-      this.workerFn.call(null, job._source.payload, function (err, cbOutput) {
-        if (err) return reject(err);
-        resolve(cbOutput);
-      });
+      resolve(this.workerFn(job._source.payload));
 
       setTimeout(function () {
         reject(new WorkerTimeoutError({