lib/maglev/active_job/reliable.rb
# acknowledge the job is done. Provided here as its own method so that a complex
# job could ack before it completes, if the need is there. This method is idempotent.
acknowledge the job is done. Provided here as its own method so that a complex
job could ack before it completes, if the need is there. This method is idempotent.
acknowledge the job is done . Provided here as its own method so that a complex job could ack before it completes if the need is there . This method is idempotent .
def ack!
        if @rely
          begin
            MagLev.redis {|r| r.hdel(Reliable.key, rely_key) }
            @rely = false
          rescue => ex
            MagLev.logger.report(:error, "Failed to delete reliable key", ex)
          end
          true
        else
          false
        end
      end
def ack! if @rely begin MagLev . redis { | r | r . hdel ( Reliable . key , rely_key ) } @rely = false rescue => ex MagLev . logger . report ( :error , "Failed to delete reliable key" , ex ) end true else false end end
acknowledge the job is done.
acknowledge the job is done .