         @_set_expiration cb_wf
     ], (err, expire_state) =>
       if err? or expire_state is 0
-        @log "RESERVE_ERROR: Failed to ensure reservation, will try again in 10 minutes. expire_status:", expire_state, err
+        @log "RESERVE: Failed to ensure reservation, will try again in 10 minutes. expire_status:", expire_state, err
 
   _set_expiration: (cb) ->
     return setImmediate cb unless @_reserve_key?  # nothing reserved here

    clearInterval @_heartbeat if @_heartbeat? # we're done here, no more heartbeats
    @_init_redis()
    @_redis.del @_reserve_key, (err, state) =>
      @log "RESERVE_ERROR: Failed to RELEASE LOCK for #{@_reserve_key} on #{@_reserve_val}" if err?
      @log 'RESERVE_RELEASED', @_reserve_key unless err?
      delete @_reserve_key  # loose the lock
      delete @_reserve_val
      cb err, state or !err?

    async.until(
      => @_reserve_key?
      (cb_u) => @lock resource, (err, lock_status) =>
        @log "RESERVE: Attempted to reserve #{resource}:", lock_status, err
        setTimeout cb_u, 1000, err  # try every second
      (err) =>
        @log "RESERVE: Failed to reserve resource", err if err?
        @log "RESERVE: Done waiting for resource. reserve_state:", @_reserve_key?
        return cb err, @_reserve_key?
    )
