2016-10-10 07:40:14 +00:00
|
|
|
class UpdateMergeRequestsWorker
|
|
|
|
include Sidekiq::Worker
|
2016-10-21 16:13:41 +00:00
|
|
|
include DedicatedSidekiqQueue
|
2016-10-10 07:40:14 +00:00
|
|
|
|
|
|
|
def perform(project_id, user_id, oldrev, newrev, ref)
|
|
|
|
project = Project.find_by(id: project_id)
|
|
|
|
return unless project
|
|
|
|
|
|
|
|
user = User.find_by(id: user_id)
|
|
|
|
return unless user
|
|
|
|
|
2017-11-13 19:56:08 +00:00
|
|
|
# TODO: remove this benchmarking when we have rich logging
|
|
|
|
time = Benchmark.measure do
|
|
|
|
MergeRequests::RefreshService.new(project, user).execute(oldrev, newrev, ref)
|
|
|
|
end
|
|
|
|
|
|
|
|
log_args = ["elapsed=#{time.real}"]
|
|
|
|
method(__method__).parameters.map do |_, p|
|
|
|
|
pname = p.to_s
|
|
|
|
log_args << [pname, binding.local_variable_get(pname)].join('=')
|
|
|
|
end
|
|
|
|
|
|
|
|
Rails.logger.info("UpdateMergeRequestsWorker#perform #{log_args.join(',')}")
|
2016-10-10 07:40:14 +00:00
|
|
|
end
|
|
|
|
end
|