Contents

module Marty::Diagnostic; class DelayedJobWorkers < Base
  diagnostic_fn do
    my_ip = Node.my_ip
    conns = Node.get_postgres_connections[Database.db_name]
    workers = conns.map do |c|
      ip   = c['client_addr'] || '127.0.0.1'
      name = c['application_name']
      name if name.include?('delayed') && (ip == my_ip || ip == '127.0.0.1')
    end.compact.uniq.count

    workers.zero? ? error(workers) : workers
  end
end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
marty-2.3.0	other/marty/diagnostic/delayed_job_workers.rb