Class: RailsPulse::Job

Inherits:
ApplicationRecord show all
Includes:
HasPerformanceStatus, Taggable
Defined in:
app/models/rails_pulse/job.rb

Constant Summary

Constants included from Taggable

Taggable::MAX_TAG_LENGTH, Taggable::TAG_NAME_REGEX

Class Method Summary collapse

Instance Method Summary collapse

Methods included from HasPerformanceStatus

#performance_status

Methods included from Taggable

#add_tag, #has_tag?, #remove_tag, #tag_list, #tag_list=

Class Method Details

.ransackable_associations(auth_object = nil) ⇒ Object 



22
23
24
 
# File 'app/models/rails_pulse/job.rb', line 22

def self.ransackable_associations(auth_object = nil)
  %w[runs]
end

.ransackable_attributes(auth_object = nil) ⇒ Object 



18
19
20
 
# File 'app/models/rails_pulse/job.rb', line 18

def self.ransackable_attributes(auth_object = nil)
  %w[id name queue_name runs_count failures_count retries_count avg_duration p95_duration p99_duration]
end

Instance Method Details

#apply_run!(run) ⇒ Object 



30
31
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
59
60
61
62
63
64
65
 
# File 'app/models/rails_pulse/job.rb', line 30

def apply_run!(run)
  return unless run.duration

  duration = run.duration.to_f

  with_lock do
    reload
    total_runs = runs_count.to_i
    previous_total = [ total_runs - 1, 0 ].max
    previous_average = avg_duration.to_f

    new_average = if previous_total.zero?
      duration
    else
      ((previous_average * previous_total) + duration) / (previous_total + 1)
    end

    recent_durations = runs.where.not(duration: nil)
                           .order(occurred_at: :desc)
                           .limit(100)
                           .pluck(:duration)
                           .sort

    updates = {
      avg_duration: new_average,
      p95_duration: RailsPulse::Statistics.calculate_percentile(recent_durations, 0.95) || 0.0,
      p99_duration: RailsPulse::Statistics.calculate_percentile(recent_durations, 0.99) || 0.0
    }
    updates[:failures_count] = failures_count + 1 if run.failure_like_status?
    updates[:retries_count] = retries_count + 1 if run.status == "retried"

    update!(updates)
  end
rescue ActiveRecord::RecordNotFound
  RailsPulse.logger.warn "RailsPulse::Job #{id} was deleted concurrently; skipping cache update for run #{run.id}"
end

#failure_rate ⇒ Object 



67
68
69
70
71
 
# File 'app/models/rails_pulse/job.rb', line 67

def failure_rate
  return 0.0 if runs_count.zero?

  ((failures_count.to_f / runs_count) * 100).round(2)
end

#to_breadcrumb ⇒ Object 



77
78
79
 
# File 'app/models/rails_pulse/job.rb', line 77

def to_breadcrumb
  name.split("/").map(&:camelize).join("::")
end

#to_param ⇒ Object 



73
74
75
 
# File 'app/models/rails_pulse/job.rb', line 73

def to_param
  id.to_s
end