diff --git a/lib/solid_queue/processes/runnable.rb b/lib/solid_queue/processes/runnable.rb index 33b441f6..7f1a68e9 100644 --- a/lib/solid_queue/processes/runnable.rb +++ b/lib/solid_queue/processes/runnable.rb @@ -7,6 +7,7 @@ module Runnable attr_writer :mode def start + # Scheduler Lifecycle - 1 - Schedule started boot if running_async? diff --git a/lib/solid_queue/scheduler.rb b/lib/solid_queue/scheduler.rb index 3cec90fa..7285ec8b 100644 --- a/lib/solid_queue/scheduler.rb +++ b/lib/solid_queue/scheduler.rb @@ -8,7 +8,9 @@ class Scheduler < Processes::Base attr_reader :recurring_schedule after_boot :run_start_hooks + # Scheduler Lifecycle - 2 - Schedule recurreing tasks after_boot :schedule_recurring_tasks + # Scheduler Lifecycle - 4 - Unschedule recurring tasks before_shutdown :unschedule_recurring_tasks before_shutdown :run_stop_hooks after_shutdown :run_exit_hooks @@ -28,6 +30,7 @@ def metadata def run loop do + # Scheduler Lifecycle - 3 - Schedule loop break if shutting_down? interruptible_sleep(SLEEP_INTERVAL)