Sha256: a8371b7526fc6d998c9f2f235ab21846abded71fc2bdb06d4104b4035a511cb5
Contents?: true
Size: 1.75 KB
Versions: 11
Compression:
Stored size: 1.75 KB
Contents
require 'spec_helper'
describe DjDashboard::Job do
describe ".fetch" do
class MyJob
def perform; end
end
class MyOtherJob
def perform; end
end
it "should return a hash for each job" do
Delayed::Job.enqueue MyJob.new
Delayed::Job.enqueue MyOtherJob.new
results = DjDashboard::Job.fetch
found_myjob = results.any? { |job| job[:name] == 'MyJob' }
found_myjob.should be_true
found_myotherjob = results.any? { |job| job[:name] == 'MyOtherJob' }
found_myotherjob.should be_true
end
it "should return each job hash with attributes: name, running, failed, pending, retrying" do
Delayed::Job.enqueue MyJob.new
Delayed::Job.enqueue MyOtherJob.new
results = DjDashboard::Job.fetch
results.each { |res| res.keys.should include(:name, :running, :failed, :pending, :retrying) }
end
it "should return running jobs" do
2.times { Delayed::Job.enqueue MyJob.new }
Delayed::Job.update_all(locked_at: Time.now)
results = DjDashboard::Job.fetch
results.first[:running].should eql(2)
end
it "should return failed jobs" do
2.times { Delayed::Job.enqueue MyJob.new }
Delayed::Job.update_all(failed_at: Time.now, attempts: 3)
results = DjDashboard::Job.fetch
results.first[:failed].should eql(2)
end
it "should return pending jobs" do
2.times { Delayed::Job.enqueue MyJob.new }
results = DjDashboard::Job.fetch
results.first[:pending].should eql(2)
end
it "should return retrying jobs" do
2.times { Delayed::Job.enqueue MyJob.new }
Delayed::Job.update_all(failed_at: Time.now)
results = DjDashboard::Job.fetch
results.first[:retrying].should eql(2)
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems