diff --git a/lib/task.js b/lib/task.js index d2e1c7f..25b6667 100644 --- a/lib/task.js +++ b/lib/task.js @@ -129,7 +129,7 @@ exports.createTask = function(f, params) { exports.putTask = function(q, task) { try { - if (q instanceof TaskQueue) { + if (q instanceof TaskQueue && task instanceof Task) { return q.put(task); } } catch(e) {