     
     # set expiration to 30 min
     @_redis.expire @_reserve_key, @lock_ttl, (err, state) =>
-      @log "RESERVE_ERROR: Reserved but failed to set expiration for #{@_reserve_key}", err if err?
+      @log "RESERVE: Failed to set expiration for #{@_reserve_key} after reservation", err if err?
       return cb null, (state is 1)
 
   _init_redis: ->

    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
        throw 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?
    )
