Move responsibility of the filtered? back to enqueue methods

This commit is contained in:
dmitry 2020-03-16 20:49:30 +01:00
parent 7e6e6eb56f
commit 70fdc9e132

@ -27,12 +27,12 @@ def performed_jobs
def enqueue(job) #:nodoc:
job_data = job_to_hash(job)
perform_or_enqueue(perform_enqueued_jobs, job, job_data)
perform_or_enqueue(perform_enqueued_jobs && !filtered?(job), job, job_data)
end
def enqueue_at(job, timestamp) #:nodoc:
job_data = job_to_hash(job, at: timestamp)
perform_or_enqueue(perform_enqueued_at_jobs, job, job_data)
perform_or_enqueue(perform_enqueued_at_jobs && !filtered?(job), job, job_data)
end
private
@ -45,7 +45,7 @@ def job_to_hash(job, extras = {})
end
def perform_or_enqueue(perform, job, job_data)
if perform && !filtered?(job)
if perform
performed_jobs << job_data
Base.execute(job.serialize)
else