Contents

module MissionControl::Jobs::Server::Workers
  def workers
    queue_adapter.workers.collect do |worker|
      MissionControl::Jobs::Worker.new(queue_adapter: queue_adapter, **worker)
    end
  end

  def find_worker(worker_id)
    if worker = queue_adapter.find_worker(worker_id)
      MissionControl::Jobs::Worker.new(queue_adapter: queue_adapter, **worker)
    else
      raise MissionControl::Jobs::Errors::ResourceNotFound, "No worker found with ID #{worker_id}"
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
mission_control-jobs-0.1.1	lib/mission_control/jobs/server/workers.rb
mission_control-jobs-0.1.0	lib/mission_control/jobs/server/workers.rb