lib/agent_runner.rb

@@ -17,12 +17,10 @@ class AgentRunner

                     @scheduler = Rufus::Scheduler.new(frequency: ENV['SCHEDULER_FREQUENCY'].presence || 0.3)
              

                 
              

                     @scheduler.every 5 do
              

                -      p :every
              

                       restart_dead_workers if @running
              

                     end
              

                 
              

                     @scheduler.every 60 do
              

                -      p :every
              

                       run_workers if @running
              

                     end
              

                 
              
@@ -121,4 +119,4 @@ end

                 require 'agents/twitter_stream_agent'
              

                 require 'agents/jabber_agent'
              

                 require 'huginn_scheduler'
              

                -require 'delayed_job_worker'
              

                +require 'delayed_job_worker'