Module: Sidekiq::Belt::Ent::PeriodicRun

Defined in:
lib/sidekiq/belt/ent/periodic_run.rb

Defined Under Namespace

Modules: SidekiqLoopsPeriodicRun

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.use! ⇒ Object 



65
66
67
68
69
70
71
72
73
74
75
76
 
# File 'lib/sidekiq/belt/ent/periodic_run.rb', line 65

def self.use!
  require("sidekiq-ent/web")
  require("sidekiq-ent/periodic")
  require("sidekiq-ent/periodic/static_loop")

  Sidekiq::Web.configure do |cfg|
    cfg.register(Sidekiq::Belt::Ent::PeriodicRun::SidekiqLoopsPeriodicRun, name: "periodic_run", tab: nil,
                                                                           index: nil)
  end
  Sidekiq::Periodic::Loop.prepend(Sidekiq::Belt::Ent::PeriodicRun)
  Sidekiq::Periodic::StaticLoop.prepend(Sidekiq::Belt::Ent::PeriodicRun)
end

Instance Method Details

#run ⇒ Object 



9
10
11
12
13
14
15
16
17
 
# File 'lib/sidekiq/belt/ent/periodic_run.rb', line 9

def run
  args = begin
    JSON.parse(options)["args"]
  rescue StandardError
    {}
  end

  Module.const_get(klass).perform_async(*args)
end