Expire values in Progressrus::Store::Redis

lib/progressrus.rb

@@ -153,7 +153,7 @@ def expired?(now: Time.now)
   def persist(force: false)
     stores.each do |store|
       begin
-        store.persist(self, force: force)
+        store.persist(self, force: force, expires_at: expires_at)
       rescue Progressrus::Store::BackendError => e
       end
     end

lib/progressrus/store/redis.rb

@@ -13,9 +13,15 @@ def initialize(instance, prefix: "progressrus", interval: 1, now: Time.now)
         @prefix        = prefix
       end
 
-      def persist(progress, now: Time.now, force: false)
+      def persist(progress, now: Time.now, force: false, expires_at: nil)
         if outdated?(progress) || force
-          redis.hset(key(progress.scope), progress.id, progress.to_serializeable.to_json)
+          key_for_scope = key(progress.scope)
+
+          redis.pipelined do
+            redis.hset(key_for_scope, progress.id, progress.to_serializeable.to_json)
+            redis.expireat(key_for_scope, expires_at) if expires_at
+          end
+
           @persisted_ats[progress.scope][progress.id] = now
         end
       rescue *BACKEND_EXCEPTIONS => e