Module: AWS::Flow::Utilities::SelfMethods Private
- Included in:
- AsyncDecider, GenericWorkflowClient
- Defined in:
- lib/aws/decider/utilities.rb
This module is part of a private API. You should avoid using this module if possible, as it may be removed or be changed in the future.
Instance Method Summary collapse
Instance Method Details
#handle_event(event, options) ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 |
# File 'lib/aws/decider/utilities.rb', line 234 def handle_event(event, ) id = [:id_lambda].call(event) if [:id_lambda] id = event.attributes [:id_methods].each {|method| id = id.send(method)} id = [:id_methods].reduce(event.attributes, :send) id = @decision_helper.send([:decision_helper_id])[id] if [:decision_helper_id] state_machine = @decision_helper[id] state_machine.consume([:consume_symbol]) if [:decision_helper_scheduled] if state_machine.done? scheduled_array = [:decision_helper_scheduled] open_request = @decision_helper.send(scheduled_array).delete(id) else scheduled_array = [:decision_helper_scheduled] open_request = @decision_helper.send(scheduled_array)[id] end if [:handle_open_request] [:handle_open_request].call(event, open_request) end end return state_machine.done? end |