lib/belated/queue.rb in belated-0.8.3 vs lib/belated/queue.rb in belated-0.9.0

@@ -1,8 +1,7 @@
 # frozen_string_literal: true
 
-require 'belated/job'
 require 'belated/logging'
 require 'belated/job_wrapper'
 require 'sorted_set'
 require 'pstore'
 class Belated
@@ -19,10 +18,10 @@
 
     def initialize(queue: Thread::Queue.new, future_jobs: SortedSet.new)
       @queue = queue
       @mutex = Mutex.new
       self.future_jobs = future_jobs
-      self.future_jobs_db = PStore.new("future_jobs_#{Belated.environment}.pstore", true) # pass true for thread safety
+      self.future_jobs_db = PStore.new("future_jobs_#{Belated.env}.pstore", true) # pass true for thread safety
     end
 
     def enqueue_future_jobs
       loop do
         job = future_jobs.min