사이드킥 잡 Telemetry

class TelemetryOutcomeMiddleware
  include Sidekiq::ServerMiddleware

  def call(_job_instance, job, queue)
    started_at = Process.clock_gettime(Process::CLOCK_MONOTONIC)
    status = "success"
    error_type = nil

    begin
      yield
    rescue => error
      status = "failed"
      error_type = classify_error(error)
      raise
    ensure
      TelemetryHttp.log(
        table: "job_attempt_completed",
        data: {
          job_id: job["jid"],
          job_name: job["class"],
          queue_name: queue,
          attempt: job.fetch("retry_count", -1) + 2,
          status: status,
          duration_ms: ((Process.clock_gettime(Process::CLOCK_MONOTONIC) - started_at) * 1000).round,
          error_type: error_type,
          release: ENV["APP_RELEASE"]
        }
      )
    end
  end
end