Packages
verk
0.13.5
1.7.3
1.7.2
1.7.1
1.7.0
1.6.4
1.6.3
1.6.2
1.6.1
1.6.0
1.5.0
1.4.1
1.4.0
1.3.0
1.2.4
1.2.3
1.2.2
1.2.1
1.2.0
1.1.1
1.1.0
1.0.2
1.0.1
1.0.0
0.14.1
0.14.0
0.13.6
0.13.5
0.13.4
0.13.3
0.13.2
0.13.1
0.13.0
0.12.1
0.12.0
0.11.1
0.11.0
0.10.0
0.9.13
0.9.12
0.9.11
0.9.10
0.9.9
0.9.8
0.9.7
0.9.6
0.9.5
0.9.4
0.9.3
0.9.2
0.9.1
0.9.0
Verk is a job processing system backed by Redis.
Current section
Files
Jump to
Current section
Files
lib/verk/log.ex
defmodule Verk.Log do
@moduledoc """
Helper module to log when a job starts, fails or finishes.
"""
require Logger
import Logger
alias Verk.{Job, Time}
def start(%Job{jid: job_id, class: module}, process_id) do
:verk
|> Application.get_env(:start_job_log_level, :info)
|> log("#{module} #{job_id} start", process_id: inspect(process_id))
end
def done(%Job{jid: job_id, class: module}, start_time, process_id) do
:verk
|> Application.get_env(:done_job_log_level, :info)
|> log("#{module} #{job_id} done: #{elapsed_time(start_time)}", process_id: inspect(process_id))
end
def fail(%Job{jid: job_id, class: module}, start_time, process_id) do
:verk
|> Application.get_env(:fail_job_log_level, :info)
|> log("#{module} #{job_id} fail: #{elapsed_time(start_time)}", process_id: inspect(process_id))
end
defp elapsed_time(start_time) do
now = Time.now
if Time.diff(start_time, now, :seconds) == 0 do
milliseconds_diff = Time.diff(start_time, now, :milliseconds)
"#{trunc(milliseconds_diff)} ms"
else
"#{trunc(Time.diff(start_time, now))} s"
end
end
end