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

Version Path
workhorse-0.4.0 lib/workhorse/enqueuer.rb
workhorse-0.3.9 lib/workhorse/enqueuer.rb
workhorse-0.3.8 lib/workhorse/enqueuer.rb
workhorse-0.3.7 lib/workhorse/enqueuer.rb
workhorse-0.3.6 lib/workhorse/enqueuer.rb
workhorse-0.3.5 lib/workhorse/enqueuer.rb
workhorse-0.3.4 lib/workhorse/enqueuer.rb
workhorse-0.3.3 lib/workhorse/enqueuer.rb
workhorse-0.3.2 lib/workhorse/enqueuer.rb
workhorse-0.3.1 lib/workhorse/enqueuer.rb
workhorse-0.3.0 lib/workhorse/enqueuer.rb