pass duration in logs as milliseconds (integer)

keypup-io · Apr 9, 2024 · a0badfc · a0badfc
1 parent 2c1a884
commit a0badfc
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/lib/cloudtasker/worker.rb b/lib/cloudtasker/worker.rb
@@ -224,16 +224,16 @@ def execute
       resp = execute_middleware_chain
 
       # Log job completion and return result
-      logger.info("Job done after #{job_duration}s") { { duration: "#{job_duration}s" } }
+      logger.info("Job done after #{job_duration}s") { { duration: job_duration * 1000 } }
       resp
     rescue DeadWorkerError => e
-      logger.info("Job dead after #{job_duration}s and #{job_retries} retries") { { duration: "#{job_duration}s" } }
+      logger.info("Job dead after #{job_duration}s and #{job_retries} retries") { { duration: job_duration * 1000 } }
       raise(e)
     rescue RetryWorkerError => e
-      logger.info("Job done after #{job_duration}s (retry requested)") { { duration: "#{job_duration}s" } }
+      logger.info("Job done after #{job_duration}s (retry requested)") { { duration: job_duration * 1000 } }
       raise(e)
     rescue StandardError => e
-      logger.info("Job failed after #{job_duration}s") { { duration: "#{job_duration}s" } }
+      logger.info("Job failed after #{job_duration}s") { { duration: job_duration * 1000 } }
       raise(e)
     end