Test scheduled jobs

spec/active_job_adapter_spec.rb

@@ -39,7 +39,7 @@ def perform(message)
 
   it 'enqueus and executes the job' do
     start_worker do
-      job = TestJob.perform_later('hello')
+      TestJob.perform_later('hello')
       sleep 2
       expect(JobBuffer.values).to eq(['hello'])
     end
@@ -53,6 +53,22 @@ def perform(message)
     end
   end
 
+  it 'should not run job enqueued in the future' do
+    start_worker do
+      TestJob.set(wait: 5.seconds).perform_later('hello')
+      sleep 2
+      expect(JobBuffer.values.empty?).to eq true
+    end
+  end
+
+  it 'should run job enqueued in the future at the specified time' do
+    start_worker do
+      TestJob.set(wait: 5.seconds).perform_later('hello')
+      sleep 10
+      expect(JobBuffer.values).to eq(['hello'])
+    end
+  end
+
   private
     def start_worker(&)
       thread = Thread.new { worker.start }