Class: SolidQueueTui::Data::ProcessesQuery

Inherits:
Object
  • Object
show all
Defined in:
lib/solid_queue_tui/data/processes_query.rb

Defined Under Namespace

Classes: Process

Class Method Summary collapse

Class Method Details

.fetch ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
 
# File 'lib/solid_queue_tui/data/processes_query.rb', line 32

def self.fetch
  conn = ActiveRecord::Base.connection

  rows = conn.select_all(
    "SELECT id, kind, pid, hostname, name, last_heartbeat_at, " \
    "supervisor_id, metadata, created_at " \
    "FROM solid_queue_processes WHERE kind = 'Worker' ORDER BY id"
  )

  rows.map do |row|
    metadata = parse_json(row["metadata"])

    Process.new(
      id: row["id"].to_i,
      kind: row["kind"],
      pid: row["pid"].to_i,
      hostname: row["hostname"],
      name: row["name"],
      last_heartbeat_at: parse_time(row["last_heartbeat_at"]),
      supervisor_id: row["supervisor_id"]&.to_i,
      metadata: metadata,
      created_at: parse_time(row["created_at"])
    )
  end
rescue => e
  []
end