Module: Gitlab::SidekiqLogging::LogsJobs
- Included in:
- DeduplicationLogger, PauseControlLogger, StructuredLogger
- Defined in:
- lib/gitlab/sidekiq_logging/logs_jobs.rb
Instance Method Summary collapse
- #base_message(payload) ⇒ Object
-
#parse_job(job) ⇒ Object
NOTE: Arguments are truncated/stringified in sidekiq_logging/json_formatter.rb.
Instance Method Details
#base_message(payload) ⇒ Object
6 7 8 |
# File 'lib/gitlab/sidekiq_logging/logs_jobs.rb', line 6 def (payload) "#{payload['class']} JID-#{payload['jid']}" end |
#parse_job(job) ⇒ Object
NOTE: Arguments are truncated/stringified in sidekiq_logging/json_formatter.rb
11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
# File 'lib/gitlab/sidekiq_logging/logs_jobs.rb', line 11 def parse_job(job) # Error information from the previous try is in the payload for # displaying in the Sidekiq UI, but is very confusing in logs! job = job.except( 'exception.backtrace', 'exception.class', 'exception.message', 'exception.sql', 'error_message', 'error_class', 'error_backtrace', 'failed_at' ) job['class'] = job.delete('wrapped') if job['wrapped'].present? job['job_size_bytes'] = Sidekiq.dump_json(job['args']).bytesize job['args'] = ['[COMPRESSED]'] if ::Gitlab::SidekiqMiddleware::SizeLimiter::Compressor.compressed?(job) # Add process id params job['pid'] = ::Process.pid job.delete('args') unless SidekiqLogArguments.enabled? job end |