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
Calls superclass method
AWS::Flow::DecisionStateMachineBase::new
# 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