Sha256: 16c2f70ac8a7b04c06ac03369fd3c05e54ffcbf2ba8587d544b989954f22f926

Contents?: true

Size: 816 Bytes

Versions: 5

Compression:

Stored size: 816 Bytes

Contents

module MCollective
  module Data
    class Bolt_task_data < Base
      activate_when do
        Util::Choria.new.tasks_support.tasks_compatible?
      end

      query do |taskid|
        tasks = Util::Choria.new.tasks_support

        begin
          status = tasks.task_status(taskid)

          result[:known] = true

          if status["task"]
            tasks.task_status(taskid).each do |item, value|
              value = value.utc.to_i if value.is_a?(Time)
              value = value.to_json if value.is_a?(Hash)

              result[item.intern] = value
            end

            result[:start_time] = result[:start_time].to_i
          end
        rescue
          Log.debug("Task %s was not found, returning default data. Error was: %s" % [taskid, $!.to_s])
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
choria-mcorpc-support-2.23.3 lib/mcollective/data/bolt_task_data.rb
choria-mcorpc-support-2.23.2 lib/mcollective/data/bolt_task_data.rb
choria-mcorpc-support-2.23.1 lib/mcollective/data/bolt_task_data.rb
choria-mcorpc-support-2.23.0 lib/mcollective/data/bolt_task_data.rb
choria-mcorpc-support-2.23.0.pre lib/mcollective/data/bolt_task_data.rb