Sha256: ea1629f20226e92f8477a8205bf5f3788a782672eb58df5bfb8e7d89292843a8
Contents?: true
Size: 877 Bytes
Versions: 2
Compression:
Stored size: 877 Bytes
Contents
module Workhorse module Enqueuer # Enqueue any object that is serializable and has a `perform` method def enqueue(job, queue: nil) return DbJob.create!( queue: queue, handler: Marshal.dump(job) ) end # Enqueue an ActiveJob job def enqueue_active_job(job) enqueue job, queue: job.queue_name 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
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
workhorse-0.1.0 | lib/workhorse/enqueuer.rb |
workhorse-0.0.3 | lib/workhorse/enqueuer.rb |