module MissionControl::Jobs::Server::RecurringTasks
def find_recurring_task(task_id)
def find_recurring_task(task_id) if task = queue_adapter.find_recurring_task(task_id) MissionControl::Jobs::RecurringTask.new(queue_adapter: queue_adapter, **task) else raise MissionControl::Jobs::Errors::ResourceNotFound, "Recurring task with id '#{task_id}' not found" end end
def recurring_tasks
def recurring_tasks queue_adapter.recurring_tasks.collect do |task| MissionControl::Jobs::RecurringTask.new(queue_adapter: queue_adapter, **task) end.sort_by(&:id) end