Class: Task

Inherits:
Object
  • Object
show all
Extended by:
Observable
Includes:
GlobalID::Identification, Mongoid::Document, Mongoid::Uuid, MongoidEnumerable
Defined in:
app/models/task.rb

Instance Method Summary collapse

Methods included from Observable

add_observer, extended, observer_instances_for, remove_observer

Instance Method Details

#calculate_millisecond_span(start, finish) ⇒ Object 



101
102
103
 
# File 'app/models/task.rb', line 101

def calculate_millisecond_span(start, finish)
  ((finish - start) * 1.day.in_milliseconds).to_i if finish.present? && start.present?
end

#force_retry! ⇒ Object 



105
106
107
108
109
 
# File 'app/models/task.rb', line 105

def force_retry!
  update(try_count: 0)
  retry!
  RunTasksJob.perform_later(execution_type: execution_type)
end

#generate_runner_id ⇒ Object 



119
120
121
122
123
124
125
 
# File 'app/models/task.rb', line 119

def generate_runner_id
  prefix = name.gsub("_", "-").parameterize
  random_suffix = SecureRandom.alphanumeric(8).downcase
  max_prefix_size = Constants::Runner::MAX_NAME_SIZE - random_suffix.length - 1

  "#{prefix.truncate(max_prefix_size, omission: "")}-#{random_suffix}"
end

#get_logs ⇒ Object 



55
56
57
58
59
60
61
 
# File 'app/models/task.rb', line 55

def get_logs
  if started?
    slot.node.runner_service(:fetch_logs).perform(task: self)
  else
    logs.try(:data)
  end
end

#mark_as_retry(error: nil) ⇒ Object 



69
70
71
72
73
74
75
76
77
78
79
 
# File 'app/models/task.rb', line 69

def mark_as_retry(error: nil)
  update!(error: error)

  if try_count < Settings.task_retry_count
    update(try_count: try_count + 1, slot: nil, runner_id: nil)
    retry!
    RunTasksJob.perform_later(execution_type: execution_type)
  else
    failed!
  end
end

#mark_as_started!(runner_id:, slot:) ⇒ Object 



63
64
65
66
67
 
# File 'app/models/task.rb', line 63

def mark_as_started!(runner_id:, slot:)
  update!(started_at: Time.zone.now, runner_id: runner_id, slot: slot)

  started!
end

#milliseconds_running ⇒ Object 



89
90
91
92
93
94
95
 
# File 'app/models/task.rb', line 89

def milliseconds_running
  if completed? || failed?
    calculate_millisecond_span(started_at, finished_at)
  elsif started?
    calculate_millisecond_span(started_at, Time.zone.now.to_datetime)
  end
end

#milliseconds_waiting ⇒ Object 



81
82
83
84
85
86
87
 
# File 'app/models/task.rb', line 81

def milliseconds_waiting
  if started? || completed? || failed?
    calculate_millisecond_span(created_at, started_at)
  else
    calculate_millisecond_span(created_at, Time.zone.now.to_datetime)
  end
end

#normalize_tags ⇒ Object 



111
112
113
 
# File 'app/models/task.rb', line 111

def normalize_tags
  tags.transform_values!(&:to_s)
end

#request_id ⇒ Object 



127
128
129
 
# File 'app/models/task.rb', line 127

def request_id
  tags&.dig("request_id")
end

#seconds_running ⇒ Object 



97
98
99
 
# File 'app/models/task.rb', line 97

def seconds_running
  milliseconds_running&.div(1000)
end

#set_logs(logs) ⇒ Object 



51
52
53
 
# File 'app/models/task.rb', line 51

def set_logs(logs)
  self.logs = BSON::Binary.new(logs.dup, :generic)
end

#to_s ⇒ Object 



115
116
117
 
# File 'app/models/task.rb', line 115

def to_s
  "Task #{name} #{uuid} (#{status} runner_id: #{runner_id}) request_id=#{request_id}"
end