Async step adapter

boot_enqueue.rb

class Enqueue
  include Dry::Monads::Either::Mixin
  include IngestService::Import['enqueue']

  def call(step, input, *args)
    enqueue.call(step.operation_name, input, args)
    Right(input)
  end
end

register :enqueue, Enqueue.new

services_enqueue.rb

module Service
  class Enqueue
    class Job
      include Sidekiq::Worker

      def perform(identifier, *args)
        operation = Container[identifier]
        operation.call_from_queue(args)
      end
    end

    def call(identifier, *args)
      operation = Container[identifier]
      Job.perform_async(identifier, *operation.to_queue(*args))
    end
  end
end