methods for tracking dynflow task progress example

dynflow_task_progress.rb

module Actions
  module Candlepin
    module Owner
      class UpstreamUpdate < Candlepin::Abstract
        input_format do
          param :organization_id
          param :upstream
        end

        def run
          organization = ::Organization.find(input[:organization_id])
          output[:response] = organization.redhat_provider.owner_upstream_update(input[:upstream], {})
          output[:progress] = 0
          (0...1000).each do |var|
            sleep 1
            output[:progress] += 1
          end
        end

        # relative weights are used to calculate percent complete based on subtasks done
        def run_progress_weight
          1_000_000
        end

        def finalize_progress_weight
          42
        end

        def run_progress
          # this is run every time the task is polled
          # new instance each time, so won't have access to @instance variables
          # however, it does have access to output & input
          output[:progress] / 1000
        end
      end
    end
  end
end