dymk/redux-scraper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bulk-enqueue in api controllers

Browse Source
This commit is contained in:
Dylan Knutson
2023-03-28 15:55:18 +09:00
parent 31d78ad0b9
commit 4a8f4f241b
2 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
app/controllers/domain/fa/api_controller.rb
View File

@@ -196,9 +196,11 @@ class Domain::Fa::ApiController < ApplicationController
end
def enqueue_deferred!
while job = (@deferred_jobs || []).shift
klass, args, priority, queue = job
klass.set(priority: priority, queue: queue).perform_later(args)
GoodJob::Bulk.enqueue do
while job = (@deferred_jobs || []).shift
klass, args, priority, queue = job
klass.set(priority: priority, queue: queue).perform_later(args)
end
end
end

8
app/controllers/domain/twitter/api_controller.rb
View File

@@ -31,9 +31,11 @@ class Domain::Twitter::ApiController < ApplicationController
end
def enqueue_deferred!
while job = (@deferred_jobs || []).shift
klass, args, priority, queue = job
klass.set(priority: priority, queue: queue).perform_later(args)
GoodJob::Bulk.enqueue do
while job = (@deferred_jobs || []).shift
klass, args, priority, queue = job
klass.set(priority: priority, queue: queue).perform_later(args)
end
end
end