           @emitConsumeTask message, queueName, ironTask
 
   taskExecuted: (err, result) ->
-    @getQueue(result.queue).del result.id, (err, body) =>
+    @getQueue(result.queue).del result.id, {}, (err, body) =>
       if err
         logger.warn "IVY_WARNING Cannot delete task #{result.id} from IronMQ", err
         @manager.emit 'mqError', err

      cb = options
      options = {}

    @getQueue(options.queue).peek n: 100, (err, tasksFromQueue) =>
      scheduledTasks = {}
      unless tasksFromQueue?.length
        return cb(null, scheduledTasks)

    catch e
      logger.error 'ironTask is', ironTask
      logger.error "IVY_IRONMQ_ERROR Retrieve tasks that cannot be parsed as JSON, deleting from queue: #{ironTask}", e
      @getQueue().del ironTask.id, {}, (err, body) =>
        if err
          logger.warn "IVY_WARNING Cannot delete task from IronMQ", err
          @manager.emit 'mqError', err
