class AWS::Flow::ActivityDecisionStateMachine

@api private

Attributes

attributes[R]

Public Class Methods

new(decision_id, attributes) click to toggle source

Creates a new ‘ActivityDecisionStateMachine`.

@param [DecisionID] decision_id

@param attributes

# File lib/aws/decider/state_machines.rb, line 166
def initialize(decision_id, attributes)
  @attributes = attributes
  super(decision_id)
end

Public Instance Methods

create_request_cancel_activity_task_decision() click to toggle source
# File lib/aws/decider/state_machines.rb, line 204
def create_request_cancel_activity_task_decision
  { :decision_type => "RequestCancelActivityTask",
    :request_cancel_activity_task_decision_attributes => {:activity_id => @attributes[:decision_id]} }
end
create_schedule_activity_task_decision() click to toggle source
# File lib/aws/decider/state_machines.rb, line 184
def create_schedule_activity_task_decision
  options = @attributes[:options]
  attribute_type = :schedule_activity_task_decision_attributes
  result = { :decision_type => "ScheduleActivityTask",
      attribute_type =>
      {
        :activity_type =>
        {
          :name => @attributes[:activity_type].name.to_s,
          :version => options.version.to_s
        },
        :activity_id => @attributes[:decision_id].to_s,
      }
  }
  task_list = options.task_list ? {:task_list => {:name => options.task_list}} : {}
  to_add = options.get_options([:heartbeat_timeout, :schedule_to_close_timeout, :task_priority, :schedule_to_start_timeout, :start_to_close_timeout, :input], task_list)
  result[attribute_type].merge!(to_add)
  result
end
get_decision() click to toggle source
# File lib/aws/decider/state_machines.rb, line 175
def get_decision
  case @current_state
  when :created
    return create_schedule_activity_task_decision
  when :cancelled_after_initiated
    return create_request_cancel_activity_task_decision
  end
end