Class: AWS::Flow::ActivityDefinition

Inherits:
Object
  • Object
show all
Defined in:
lib/aws/decider/activity_definition.rb

Overview

Defines an executable activity.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(instance, activity_method, registration_options, execution_options, converter) ⇒ ActivityDefinition

Creates a new ActivityDefinition instance.

Parameters:

  • instance (Object)
  • activity_method (Symbol) —

    The method to run when #execute is called.

  • registration_options (Hash)
  • execution_options (Hash) —

    The AWS::Flow::ActivityOptions for this activity.

  • converter (Object) 


41
42
43
44
45
46
47
 
# File 'lib/aws/decider/activity_definition.rb', line 41

def initialize(instance, activity_method, registration_options, execution_options, converter)
  @instance = instance
  @activity_method = activity_method
  @registration_options = registration_options
  @execution_options = execution_options
  @converter = converter
end

Instance Attribute Details

#execution_options ⇒ Object

Returns the value of attribute execution_options.



25
26
27
 
# File 'lib/aws/decider/activity_definition.rb', line 25

def execution_options
  @execution_options
end

Instance Method Details

#execute(input, context) ⇒ Object

Executes the activity.

Parameters:

  • input (Object) —

    Additional input for the activity execution.

  • context (ActivityExecutionContext) —

    The context for the activity execution.



57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
 
# File 'lib/aws/decider/activity_definition.rb', line 57

def execute(input, context)
  begin
    @instance._activity_execution_context = context
    # Since we encode all the inputs in some converter, and these inputs
    # are not "true" Ruby objects yet, there is no way for that input to
    # be an instance of the NilClass(the only thing that responds true to
    # .nil?) and thus we can be assured that if input.nil?, then the
    # method had no input.
    if input.nil?
      result = @instance.send(@activity_method)
    else
      ruby_input = @converter.load input
      result = @instance.send(@activity_method, *ruby_input)
    end
  rescue Exception => e
    raise e if e.is_a? CancellationException

    # Check if serialized exception violates the 32k limit and truncate it
    reason, converted_failure = AWS::Flow::Utilities::check_and_truncate_exception(e, @converter)

    # Wrap the exception that we got into an ActivityFailureException so
    # that the task poller can handle it properly.
    raise ActivityFailureException.new(reason, converted_failure)
  ensure
    @instance._activity_execution_context = nil
  end
  converted_result = @converter.dump(result)
  # We are going to have to convert this object into a string to submit it, and that's where the 32k limit will be enforced, so it's valid to turn the object to a string and check the size of the result
  if converted_result.to_s.size > FlowConstants::DATA_LIMIT
    return converted_result, result, true
  end
  return converted_result, result, false
end