INNER CODE UNIT · Ruby

ActiveWorker

reidmorrison/rocketjob · lib/rocket_job/active_worker.rb:3

  class ActiveWorker
    # When this server started working on this job / slice
    attr_accessor :started_at

    attr_accessor :job
    attr_reader :name

    # Returns [Hash<String:ActiveWorker>] hash of all servers sorted by name
    # and what they are currently working on.
    # Returns {} if no servers are currently busy doing any work
    #
    # Parameters
    #   server_name: [String]
    #     Only jobs running on the specified server
    def self.all(server_name = nil)
      servers = []
      # Need paused, failed or aborted since servers may still be working on active slices
      query = RocketJob::Job.where(:state.in => %i[running paused failed aborted])

View source record →