Class: Pgbus::RecurringTask

Inherits:
BusRecord
  • Object
show all
Defined in:
app/models/pgbus/recurring_task.rb

Class Method Summary collapse

Methods inherited from BusRecord

disconnect_all_pools!

Class Method Details

.sync_from_config!(tasks_hash) ⇒ Object

Sync static tasks from configuration. Creates new tasks, updates existing ones, removes stale ones.



16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'app/models/pgbus/recurring_task.rb', line 16

def self.sync_from_config!(tasks_hash)
  transaction do
    task_keys = tasks_hash.keys

    # Upsert all configured tasks
    tasks_hash.each do |key, options|
      options = options.transform_keys(&:to_s)
      record = find_or_initialize_by(key: key)
      record.assign_attributes(
        class_name: options["class"],
        command: options["command"],
        schedule: options["schedule"],
        queue_name: options["queue"],
        arguments: options["args"],
        priority: options.fetch("priority", 0).to_i,
        description: options["description"],
        static: true
      )
      record.save!
    end

    # Remove static tasks no longer in config
    static_tasks.where.not(key: task_keys).delete_all
  end
end