diff --git a/lib/resque_cleaner.rb b/lib/resque_cleaner.rb index 9400ed0..70d73dc 100644 --- a/lib/resque_cleaner.rb +++ b/lib/resque_cleaner.rb @@ -226,7 +226,10 @@ def all(index=0,count=1) jobs = @cleaner.failure.all( index, count) jobs = [] unless jobs jobs = [jobs] unless jobs.is_a?(Array) - jobs.each{|j| j.extend FailedJobEx} + jobs = jobs.select do |job| + job.extend FailedJobEx + job && job["payload"] + end jobs end