Sha256: a646f08451329e4d473a5ba95fb4e8c6ccffa97303de3d48062b36f6504da7b1
Contents?: true
Size: 806 Bytes
Versions: 22
Compression:
Stored size: 806 Bytes
Contents
# frozen_string_literal: true
module Karafka
# Karafka framework Cli
class Cli < Thor
# Worker Karafka Cli action
class Worker < Base
desc 'Start the Karafka Sidekiq worker (short-cut alias: "w")'
option aliases: 'w'
# Start the Karafka Sidekiq worker
# @param params [Array<String>] additional params that will be passed to sidekiq, that way we
# can override any default Karafka settings
def call(*params)
puts 'Starting Karafka worker'
config = "-C #{Karafka::App.root.join('config/sidekiq.yml')}"
req = "-r #{Karafka.boot_file}"
env = "-e #{Karafka.env}"
cli.info
cmd = "bundle exec sidekiq #{env} #{req} #{config} #{params.join(' ')}"
puts(cmd)
exec(cmd)
end
end
end
end
Version data entries
22 entries across 22 versions & 2 rubygems