We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7a5d43e commit 4c75a01Copy full SHA for 4c75a01
lib/solid_queue/dispatcher.rb
@@ -51,6 +51,10 @@ def unload_recurring_schedule
51
recurring_schedule.unload_tasks
52
end
53
54
+ def all_work_completed?
55
+ SolidQueue::ScheduledExecution.none? && recurring_schedule.empty?
56
+ end
57
+
58
def set_procline
59
procline "waiting"
60
lib/solid_queue/dispatcher/recurring_schedule.rb
@@ -11,6 +11,10 @@ def initialize(tasks)
11
@scheduled_tasks = Concurrent::Hash.new
12
13
14
+ def empty?
15
+ configured_tasks.empty?
16
17
18
def load_tasks
19
configured_tasks.each do |task|
20
load_task(task)
0 commit comments