Sha256: bf0a6ba47733a8040a4d6665b5294698c2b502bc5294880657125cac8032041a
Contents?: true
Size: 676 Bytes
Versions: 19
Compression:
Stored size: 676 Bytes
Contents
# frozen_string_literal: true
require "logger"
require "active_support/tagged_logging"
module AcidicJob
class Logger < ::Logger
def log_run_event(msg, job = nil, run = nil)
tags = [
run&.idempotency_key,
inspect_name(job)
].compact
tagged(*tags) { debug(msg) }
end
def inspect_name(obj)
return if obj.nil?
obj.inspect.split.first.remove("#<")
end
end
def self.logger
@logger ||= ActiveSupport::TaggedLogging.new(AcidicJob::Logger.new($stdout, level: :debug))
end
def self.silence_logger!
@logger = ActiveSupport::TaggedLogging.new(AcidicJob::Logger.new(IO::NULL, level: :debug))
end
end
Version data entries
19 entries across 19 versions & 1 rubygems