24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
# File 'lib/periodically/job.rb', line 24
def execute_instance(instance)
return_value =
begin
instance.send(@method)
rescue => e
Periodically::ErrorHandler.handle_error(e, instance)
new_error_count = Periodically::ErrorCounts.increment(instance_key(instance))
Periodically::Locks.lock(instance_key(instance), DEFAULT_ERROR_DELAY.call(new_error_count))
Periodically::ErrorMessages.store(instance_key(instance), e)
return
end
if return_value.is_a?(Periodically::Defer::DeferInstance)
Periodically::Locks.lock(instance_key(instance), return_value.duration)
elsif return_value.is_a?(Periodically::Defer::DeferJob)
Periodically::Locks.lock(@job_key, return_value.duration)
elsif return_value.is_a?(Periodically::Defer::DeferClass)
Periodically::Locks.lock(@class_key, return_value.duration)
end
Periodically::ErrorCounts.reset(instance_key(instance))
end
|