We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 893b23f commit 442ee97Copy full SHA for 442ee97
lib/solid_queue/scheduler.rb
@@ -51,11 +51,15 @@ def stop_concurrency_maintenance
51
end
52
53
def expire_semaphores
54
- Semaphore.expired.in_batches(of: batch_size, &:delete_all)
+ wrap_in_app_executor do
55
+ Semaphore.expired.in_batches(of: batch_size, &:delete_all)
56
+ end
57
58
59
def unblock_blocked_executions
- BlockedExecution.unblock(batch_size)
60
61
+ BlockedExecution.unblock(batch_size)
62
63
64
65
def initial_jitter
0 commit comments