Sha256: 67f3c4046e07615b2e0733db36bb2904e8748937e2fbf25ee9966c18d3a95228

Contents?: true

Size: 465 Bytes

Versions: 10

Compression:

Stored size: 465 Bytes

Contents

# frozen_string_literal: true
module Shipit
  class ReapDeadTasksJob < BackgroundJob
    include BackgroundJob::Unique
    queue_as :default

    def perform
      Rails.logger.info("Reaping #{zombie_tasks.size} running tasks.")
      zombie_tasks.each do |task|
        Rails.logger.info("Reaping task #{task.id}: #{task.title}")
        task.report_dead!
      end
    end

    private

    def zombie_tasks
      @zombie_tasks ||= Task.zombies
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version Path
shipit-engine-0.39.0 app/jobs/shipit/reap_dead_tasks_job.rb
shipit-engine-0.38.0 app/jobs/shipit/reap_dead_tasks_job.rb
shipit-engine-0.37.0 app/jobs/shipit/reap_dead_tasks_job.rb
shipit-engine-0.36.1 app/jobs/shipit/reap_dead_tasks_job.rb
shipit-engine-0.36.0 app/jobs/shipit/reap_dead_tasks_job.rb
shipit-engine-0.35.1 app/jobs/shipit/reap_dead_tasks_job.rb
shipit-engine-0.35.0 app/jobs/shipit/reap_dead_tasks_job.rb
shipit-engine-0.34.0 app/jobs/shipit/reap_dead_tasks_job.rb
shipit-engine-0.33.0 app/jobs/shipit/reap_dead_tasks_job.rb
shipit-engine-0.32.0 app/jobs/shipit/reap_dead_tasks_job.rb