     unless @_redis?
       @_redis = redis.createClient @port, @host, { retry_max_delay:100, connect_timeout: 500, max_attempts: 10 }
       @_redis.once 'error', (err) =>
-        @log "RESERVE_ERROR: connecting to REDIS: #{@host}:#{@port}.", err
+        @log "RESERVE: Error connecting to REDIS: #{@host}:#{@port}.", err
         throw err

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

        @_set_expiration cb_wf
    ], (err, expire_state) =>
      if err? or expire_state is 0
        @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
