Class: StuckCiBuildsWorker

Inherits:
Object
  • Object
show all
Includes:
Sidekiq::Worker
Defined in:
app/workers/stuck_ci_builds_worker.rb

Constant Summary collapse

BUILD_STUCK_TIMEOUT =
1.day

Instance Method Summary collapse

Instance Method Details

#performObject


6
7
8
9
10
11
12
13
14
15
16
17
# File 'app/workers/stuck_ci_builds_worker.rb', line 6

def perform
  Rails.logger.info 'Cleaning stuck builds'

  builds = Ci::Build.running_or_pending.where('updated_at < ?', BUILD_STUCK_TIMEOUT.ago)
  builds.find_each(batch_size: 50).each do |build|
    Rails.logger.debug "Dropping stuck #{build.status} build #{build.id} for runner #{build.runner_id}"
    build.drop
  end

  # Update builds that failed to drop
  builds.update_all(status: 'failed')
end