1 files changed, 2 insertions, 1 deletions
diff --git a/lib/internal/parallel.js b/lib/internal/parallel.js
index d7c5cd9..70993d3 100644
--- a/lib/internal/parallel.js
+++ b/lib/internal/parallel.js
@@ -1,13 +1,14 @@
 import noop from 'lodash/noop';
 import isArrayLike from 'lodash/isArrayLike';
 import rest from './rest';
+import wrapAsync from './wrapAsync';
 
 export default function _parallel(eachfn, tasks, callback) {
     callback = callback || noop;
     var results = isArrayLike(tasks) ? [] : {};
 
     eachfn(tasks, function (task, key, callback) {
-        task(rest(function (err, args) {
+        wrapAsync(task)(rest(function (err, args) {
             if (args.length <= 1) {
                 args = args[0];
             }