Contents

module Importo
  class SidekiqBatchAdapter
    attr_reader :description
    attr_accessor :properties
    attr_writer :instance

    def initialize
      @instance = Sidekiq::Batch.new
    end

    delegate :description=, :status, to: :@instance

    def on_success(job)
      @instance.on(:complete, job.constantize, properties)
    end

    def add
      @instance.jobs do
        yield
      end
    end

    def finished?
      @instance.status.complete?
    end

    class << self
      def find(id)
        instance = new
        instance.instance = Sidekiq::Batch.new(id)
        instance
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
importo-3.0.21	app/adapters/importo/sidekiq_batch_adapter.rb
importo-3.0.20	app/adapters/importo/sidekiq_batch_adapter.rb
importo-3.0.19	app/adapters/importo/sidekiq_batch_adapter.rb
importo-3.0.18	app/adapters/importo/sidekiq_batch_adapter.rb