|
|
|
@ -11,6 +11,7 @@ end
|
|
|
|
|
Resque::Metrics.on_job_complete do |job_class, queue, time|
|
|
|
|
|
CartoDB::Resque::Metrics.logger.info(
|
|
|
|
|
{:event => :job_complete,
|
|
|
|
|
:timestamp => Time.now.utc.iso8601,
|
|
|
|
|
:job_class => job_class.to_s,
|
|
|
|
|
:queue => queue,
|
|
|
|
|
:time => time}.to_json
|
|
|
|
@ -20,6 +21,7 @@ end
|
|
|
|
|
Resque::Metrics.on_job_enqueue do |job_class, queue, time|
|
|
|
|
|
CartoDB::Resque::Metrics.logger.info(
|
|
|
|
|
{:event => :job_enqueue,
|
|
|
|
|
:timestamp => Time.now.utc.iso8601,
|
|
|
|
|
:job_class => job_class.to_s,
|
|
|
|
|
:queue => queue,
|
|
|
|
|
:time => time}.to_json
|
|
|
|
@ -29,6 +31,7 @@ end
|
|
|
|
|
Resque::Metrics.on_job_fork do |job_class, queue|
|
|
|
|
|
CartoDB::Resque::Metrics.logger.info(
|
|
|
|
|
{:event => :job_fork,
|
|
|
|
|
:timestamp => Time.now.utc.iso8601,
|
|
|
|
|
:job_class => job_class.to_s,
|
|
|
|
|
:queue => queue}.to_json
|
|
|
|
|
)
|
|
|
|
@ -37,6 +40,7 @@ end
|
|
|
|
|
Resque::Metrics.on_job_failure do |job_class, queue, time|
|
|
|
|
|
CartoDB::Resque::Metrics.logger.info(
|
|
|
|
|
{:event => :job_failure,
|
|
|
|
|
:timestamp => Time.now.utc.iso8601,
|
|
|
|
|
:job_class => job_class.to_s,
|
|
|
|
|
:queue => queue,
|
|
|
|
|
:time => time}.to_json
|
|
|
|
|