lib/progressrus/store/redis.rb in progressrus-0.0.3 vs lib/progressrus/store/redis.rb in progressrus-0.0.4

@@ -11,12 +11,18 @@
         @persisted_ats = Hash.new({})
         @interval      = interval
         @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
         raise Progressrus::Store::BackendError.new(e)
       end