Commit 509b7ab3 authored by Dylan Griffith's avatar Dylan Griffith

Log duration of ProcessBookkeepingService#execute

parent 3ad8416e
...@@ -54,6 +54,8 @@ module Elastic ...@@ -54,6 +54,8 @@ module Elastic
private private
def execute_with_redis(redis) def execute_with_redis(redis)
start_time = Time.now
specs = redis.zrangebyscore(REDIS_SET_KEY, '-inf', '+inf', limit: [0, LIMIT], with_scores: true) specs = redis.zrangebyscore(REDIS_SET_KEY, '-inf', '+inf', limit: [0, LIMIT], with_scores: true)
return if specs.empty? return if specs.empty?
...@@ -82,7 +84,8 @@ module Elastic ...@@ -82,7 +84,8 @@ module Elastic
records_count: specs.count, records_count: specs.count,
failures_count: failures.count, failures_count: failures.count,
first_score: first_score, first_score: first_score,
last_score: last_score last_score: last_score,
bulk_execution_duration_s: Time.now - start_time
) )
end end
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment