lib/ci/queue/static.rb in ci-queue-0.24.0 vs lib/ci/queue/static.rb in ci-queue-0.24.1

@@ -9,10 +9,12 @@
           tests = uri.opaque.split(':').map { |t| CGI.unescape(t) }
           new(tests, config)
         end
       end
 
+      TEN_MINUTES = 60 * 10
+
       attr_reader :progress, :total
 
       def initialize(tests, config)
         @queue = tests
         @config = config
@@ -33,9 +35,17 @@
       end
 
       def populate(tests, random: nil)
         @index = tests.map { |t| [t.id, t] }.to_h
         self
+      end
+
+      def created_at=(timestamp)
+        @created_at ||= timestamp
+      end
+
+      def expired?
+        (@created_at.to_f TEN_MINUTES) < Time.now.to_f
       end
 
       def populated?
         !!defined?(@index)
       end