Module: Delayed::Backend::Base
- Included in:
- ActiveRecord::Job, ActiveRecord::Job::Failed
- Defined in:
- lib/delayed/backend/base.rb
Defined Under Namespace
Modules: ClassMethods
Constant Summary collapse
- ON_HOLD_BLOCKER =
"blocker job"
- ON_HOLD_LOCKED_BY =
"on hold"
- ON_HOLD_COUNT =
50
Class Method Summary collapse
Instance Method Summary collapse
- #batch? ⇒ Boolean
- #expired? ⇒ Boolean
- #failed? ⇒ Boolean (also: #failed)
- #full_name ⇒ Object
- #hold! ⇒ Object
- #inferred_max_attempts ⇒ Object
- #initialize_defaults ⇒ Object
-
#invoke_job ⇒ Object
Moved into its own method so that new_relic can trace it.
- #locked? ⇒ Boolean
- #name ⇒ Object
- #on_hold? ⇒ Boolean
- #payload_object ⇒ Object
- #payload_object=(object) ⇒ Object
- #permanent_failure(error) ⇒ Object
-
#reschedule(error = nil, time = nil) ⇒ Object
Reschedule the job in the future (when a job fails).
- #reschedule_at ⇒ Object
- #unhold! ⇒ Object
-
#unlock ⇒ Object
Unlock this job (note: not saved to DB).
Class Method Details
.included(base) ⇒ Object
19 20 21 22 23 |
# File 'lib/delayed/backend/base.rb', line 19 def self.included(base) base.extend ClassMethods base.default_priority = Delayed::NORMAL_PRIORITY base.before_save :initialize_defaults end |
Instance Method Details
#batch? ⇒ Boolean
329 330 331 |
# File 'lib/delayed/backend/base.rb', line 329 def batch? payload_object.is_a?(Delayed::Batch::PerformableBatch) end |
#expired? ⇒ Boolean
222 223 224 |
# File 'lib/delayed/backend/base.rb', line 222 def expired? expires_at && (self.class.db_time_now >= expires_at) end |
#failed? ⇒ Boolean Also known as: failed
217 218 219 |
# File 'lib/delayed/backend/base.rb', line 217 def failed? failed_at end |
#full_name ⇒ Object
289 290 291 292 293 294 295 296 |
# File 'lib/delayed/backend/base.rb', line 289 def full_name obj = payload_object rescue nil if obj.respond_to?(:full_name) obj.full_name else name end end |
#hold! ⇒ Object
357 358 359 360 361 362 |
# File 'lib/delayed/backend/base.rb', line 357 def hold! self.locked_by = ON_HOLD_LOCKED_BY self.locked_at = self.class.db_time_now self.attempts = ON_HOLD_COUNT save! end |
#inferred_max_attempts ⇒ Object
226 227 228 |
# File 'lib/delayed/backend/base.rb', line 226 def inferred_max_attempts max_attempts || Delayed::Settings.max_attempts end |
#initialize_defaults ⇒ Object
415 416 417 418 |
# File 'lib/delayed/backend/base.rb', line 415 def initialize_defaults self.queue ||= Delayed::Settings.queue self.run_at ||= self.class.db_time_now end |
#invoke_job ⇒ Object
Moved into its own method so that new_relic can trace it.
311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 |
# File 'lib/delayed/backend/base.rb', line 311 def invoke_job Delayed::Worker.lifecycle.run_callbacks(:invoke_job, self) do Delayed::Job.in_delayed_job = true begin payload_object.perform ensure Delayed::Job.in_delayed_job = false unless Rails.env.test? if Rails.version < "6.1" ::ActiveRecord::Base.clear_active_connections! else ::ActiveRecord::Base.clear_active_connections!(nil) end end end end end |
#locked? ⇒ Boolean
339 340 341 |
# File 'lib/delayed/backend/base.rb', line 339 def locked? !!(locked_at || locked_by) end |
#name ⇒ Object
278 279 280 281 282 283 284 285 286 287 |
# File 'lib/delayed/backend/base.rb', line 278 def name @name ||= begin payload = payload_object if payload.respond_to?(:display_name) payload.display_name else payload.class.name end end end |
#on_hold? ⇒ Boolean
373 374 375 |
# File 'lib/delayed/backend/base.rb', line 373 def on_hold? locked_by == "on hold" && locked_at && self.attempts == ON_HOLD_COUNT end |
#payload_object ⇒ Object
274 275 276 |
# File 'lib/delayed/backend/base.rb', line 274 def payload_object @payload_object ||= deserialize(self["handler"]) end |
#payload_object=(object) ⇒ Object
298 299 300 301 302 303 304 305 306 307 308 |
# File 'lib/delayed/backend/base.rb', line 298 def payload_object=(object) @payload_object = object self["handler"] = object.to_yaml self["tag"] = if object.respond_to?(:tag) object.tag elsif object.is_a?(Module) "#{object}.perform" else "#{object.class}#perform" end end |
#permanent_failure(error) ⇒ Object
254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 |
# File 'lib/delayed/backend/base.rb', line 254 def permanent_failure(error) begin # notify the payload_object of a permanent failure obj = payload_object obj.on_permanent_failure(error) if obj.respond_to?(:on_permanent_failure) rescue # don't allow a failed deserialization to prevent destroying the job end # optionally destroy the object destroy_self = true destroy_self = Delayed::Worker.on_max_failures.call(self, error) if Delayed::Worker.on_max_failures if destroy_self destroy else fail! end end |
#reschedule(error = nil, time = nil) ⇒ Object
Reschedule the job in the future (when a job fails). Uses an exponential scale depending on the number of failed attempts.
232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 |
# File 'lib/delayed/backend/base.rb', line 232 def reschedule(error = nil, time = nil) begin obj = payload_object return_code = obj.on_failure(error) if obj.respond_to?(:on_failure) rescue # don't allow a failed deserialization to prevent rescheduling end self.attempts += 1 unless return_code == :unlock if self.attempts >= inferred_max_attempts permanent_failure error || "max attempts reached" elsif expired? permanent_failure error || "job has expired" else time ||= reschedule_at self.run_at = time unlock save! end end |
#reschedule_at ⇒ Object
343 344 345 346 347 348 349 350 351 352 353 354 355 |
# File 'lib/delayed/backend/base.rb', line 343 def reschedule_at new_time = self.class.db_time_now + (attempts**4) + 5 begin if payload_object.respond_to?(:reschedule_at) new_time = payload_object.reschedule_at( self.class.db_time_now, attempts ) end rescue # TODO: just swallow errors from reschedule_at ? end new_time end |
#unhold! ⇒ Object
364 365 366 367 368 369 370 371 |
# File 'lib/delayed/backend/base.rb', line 364 def unhold! self.locked_by = nil self.locked_at = nil self.attempts = 0 self.run_at = [self.class.db_time_now, run_at].max self.failed_at = nil save! end |
#unlock ⇒ Object
Unlock this job (note: not saved to DB)
334 335 336 337 |
# File 'lib/delayed/backend/base.rb', line 334 def unlock self.locked_at = nil self.locked_by = nil end |