Sha256: f6262bb0baabc094c7a75b1f017d3963cf96c4d04097f418167f88dce81d8662
Contents?: true
Size: 996 Bytes
Versions: 11
Compression:
Stored size: 996 Bytes
Contents
module Workhorse module Enqueuer # Enqueue any object that is serializable and has a `perform` method def enqueue(job, queue: nil, priority: 0, perform_at: Time.now) return DbJob.create!( queue: queue, priority: priority, perform_at: perform_at, handler: Marshal.dump(job) ) end # Enqueue an ActiveJob job def enqueue_active_job(job) enqueue job, queue: job.queue_name, priority: job.priority end # Enqueue the execution of an operation by its class and params def enqueue_op(cls, *args) case args.size when 0 workhorse_args = {} op_args = {} when 1 workhorse_args = args.first op_args = {} when 2 workhorse_args, op_args = *args else fail ArgumentError, "wrong number of arguments (#{args.size + 1} for 2..3)" end job = Workhorse::Jobs::RunRailsOp.new(cls, op_args) enqueue job, workhorse_args end end end
Version data entries
11 entries across 11 versions & 1 rubygems