Enqueue build_restart event in Hub

This commit is contained in:
Ana Rosas 2016-05-13 12:59:18 -05:00
parent e876a83d86
commit 28884f9931
2 changed files with 14 additions and 7 deletions

View File

@ -54,7 +54,13 @@ class Travis::Api::App
status 400
result = false
else
Travis::Sidekiq::BuildRestart.perform_async(id: params[:id], user_id: current_user.id)
::Sidekiq::Client.push(
'queue' => 'hub',
'class' => 'Travis::Hub::Sidekiq::Worker',
'args' => ["build:restart", {id: params[:id], user_id: current_user.id}]
)
status 202
result = true
end

View File

@ -4,14 +4,15 @@ require 'multi_json'
module Travis
module Sidekiq
class BuildRestart
class ProcessingError < StandardError; end
include ::Sidekiq::Worker
sidekiq_options queue: :build_restarts
sidekiq_options queue: :hub
def perform(data)
user = User.find(data['user_id'])
Travis.service(:reset_model, user, build_id: data['id']).run
def perform(payload)
::Sidekiq::Client.push(
'queue' => 'hub',
'class' => 'Travis::Hub::Sidekiq::Worker',
'args' => ["build:restart", payload]
)
end
end