|
|
|
@ -3,7 +3,7 @@ require 'carto/configuration'
|
|
|
|
|
module CartoDB
|
|
|
|
|
module ResqueMetrics
|
|
|
|
|
def self.logger
|
|
|
|
|
@logger ||= CartoDB.standard_logger(Carto::Conf.new.log_file_path('resque_metrics.log'))
|
|
|
|
|
@logger ||= CartoDB.unformatted_logger(Carto::Conf.new.log_file_path('resque_metrics.log'))
|
|
|
|
|
end
|
|
|
|
|
end
|
|
|
|
|
end
|
|
|
|
@ -12,8 +12,8 @@ Resque::Metrics.on_job_complete do |job_class, queue, time|
|
|
|
|
|
CartoDB::ResqueMetrics.logger.info(
|
|
|
|
|
{:event => :job_complete,
|
|
|
|
|
:timestamp => Time.now.utc.iso8601,
|
|
|
|
|
:job_class => job_class.to_s,
|
|
|
|
|
:queue => queue,
|
|
|
|
|
:job_class => job_class.to_s,
|
|
|
|
|
:queue => queue,
|
|
|
|
|
:time => time}.to_json
|
|
|
|
|
)
|
|
|
|
|
end
|
|
|
|
@ -23,7 +23,7 @@ Resque::Metrics.on_job_enqueue do |job_class, queue, time|
|
|
|
|
|
{:event => :job_enqueue,
|
|
|
|
|
:timestamp => Time.now.utc.iso8601,
|
|
|
|
|
:job_class => job_class.to_s,
|
|
|
|
|
:queue => queue,
|
|
|
|
|
:queue => queue,
|
|
|
|
|
:time => time}.to_json
|
|
|
|
|
)
|
|
|
|
|
end
|
|
|
|
@ -32,7 +32,7 @@ Resque::Metrics.on_job_fork do |job_class, queue|
|
|
|
|
|
CartoDB::ResqueMetrics.logger.info(
|
|
|
|
|
{:event => :job_fork,
|
|
|
|
|
:timestamp => Time.now.utc.iso8601,
|
|
|
|
|
:job_class => job_class.to_s,
|
|
|
|
|
:job_class => job_class.to_s,
|
|
|
|
|
:queue => queue}.to_json
|
|
|
|
|
)
|
|
|
|
|
end
|
|
|
|
@ -41,8 +41,8 @@ Resque::Metrics.on_job_failure do |job_class, queue, time|
|
|
|
|
|
CartoDB::ResqueMetrics.logger.info(
|
|
|
|
|
{:event => :job_failure,
|
|
|
|
|
:timestamp => Time.now.utc.iso8601,
|
|
|
|
|
:job_class => job_class.to_s,
|
|
|
|
|
:queue => queue,
|
|
|
|
|
:job_class => job_class.to_s,
|
|
|
|
|
:queue => queue,
|
|
|
|
|
:time => time}.to_json
|
|
|
|
|
)
|
|
|
|
|
end
|
|
|
|
|