fix up queue depth selection logic

This commit is contained in:
Dylan Knutson
2023-03-28 15:59:45 +09:00
parent 4a8f4f241b
commit 8ce85c6ef0

View File

@@ -6,10 +6,10 @@ class Domain::Fa::ApiController < ApplicationController
fa_ids = (params[:fa_ids] || []).map(&:to_i)
url_names = (params[:url_names] || [])
# jobs_async = Delayed::Backend::ActiveRecord::Job.
# select(:id, :queue, :handler).
# where(queue: "manual").
# load_async
jobs_async = GoodJob::Job.
select(:id, :queue_name, :serialized_params).
where(queue_name: "manual", finished_at: nil).
load_async
users_async = Domain::Fa::User.
where(url_name: url_names).
@@ -91,20 +91,20 @@ class Domain::Fa::ApiController < ApplicationController
hash[key] = 0
end
# jobs_async.each do |job|
# queue_depths[job.payload_object.job_data["job_class"]] += 1
# end
jobs_async.each do |job|
queue_depths[job.serialized_params["job_class"]] += 1
end
# queue_depths = queue_depths.map do |key, value|
# [key.
# delete_prefix("Domain::Fa::Job::").
# split("::").
# last.
# underscore.
# delete_suffix("_job").
# gsub("_", " "),
# value]
# end.to_h
queue_depths = queue_depths.map do |key, value|
[key.
delete_prefix("Domain::Fa::Job::").
split("::").
last.
underscore.
delete_suffix("_job").
gsub("_", " "),
value]
end.to_h
render json: {
posts: posts_response,