lib/gitlab/sidekiq_middleware/size_limiter/server.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

# frozen_string_literal: true

module Gitlab
  module SidekiqMiddleware
    module SizeLimiter
      class Server
        def call(worker, job, queue)
          # This middleware should always decompress jobs regardless of the
          # limiter mode or size limit. Otherwise, this could leave compressed
          # payloads in queues that are then not able to be processed.
          ::Gitlab::SidekiqMiddleware::SizeLimiter::Compressor.decompress(job)

          yield
        end
      end
    end
  end
end