Class: AWSCDK::StepFunctionsTasks::EvaluateExpression
- Inherits:
-
AWSCDK::StepFunctions::TaskStateBase
- Object
- AWSCDK::StepFunctions::TaskStateBase
- AWSCDK::StepFunctionsTasks::EvaluateExpression
- Defined in:
- step_functions_tasks/evaluate_expression.rb
Overview
A Step Functions Task to evaluate an expression.
OUTPUT: the output of this task is the evaluated expression.
Class Method Summary collapse
Instance Method Summary collapse
-
#_next(_next) ⇒ AWSCDK::StepFunctions::Chain
Continue normal execution with the given state.
-
#add_branch(branch) ⇒ void
Add a parallel branch to this state.
-
#add_catch(handler, props = nil) ⇒ AWSCDK::StepFunctions::TaskStateBase
Add a recovery handler for this state.
-
#add_choice(condition, _next, options = nil) ⇒ void
Add a choice branch to this state.
-
#add_item_processor(processor, config = nil) ⇒ void
Add a item processor to this state.
-
#add_iterator(iteration) ⇒ void
Add a map iterator to this state.
-
#add_prefix(x) ⇒ void
Add a prefix to the stateId of this state.
-
#add_retry(props = nil) ⇒ AWSCDK::StepFunctions::TaskStateBase
Add retry configuration for this state.
- #arguments ⇒ Hash?
- #assign ⇒ Hash?
-
#bind_to_graph(graph) ⇒ void
Register this state as part of the given graph.
- #branches ⇒ Array<AWSCDK::StepFunctions::StateGraph>
- #comment ⇒ String?
- #default_choice ⇒ AWSCDK::StepFunctions::State?
- #default_choice=(value) ⇒ Object
-
#end_states ⇒ Array<AWSCDK::StepFunctions::INextable>
Continuable states of this Chainable.
-
#id ⇒ String
Descriptive identifier for this chainable.
-
#initialize(scope, id, props) ⇒ EvaluateExpression
constructor
A new instance of EvaluateExpression.
- #input_path ⇒ String?
- #iteration ⇒ AWSCDK::StepFunctions::StateGraph?
- #iteration=(value) ⇒ Object
-
#make_default(_def) ⇒ void
Make the indicated state the default choice transition of this state.
-
#make_next(_next) ⇒ void
Make the indicated state the default transition of this state.
-
#metric(metric_name, props = nil) ⇒ AWSCDK::CloudWatch::Metric
Return the given named metric for this Task.
-
#metric_failed(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Metric for the number of times this activity fails.
-
#metric_heartbeat_timed_out(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Metric for the number of times the heartbeat times out for this activity.
-
#metric_run_time(props = nil) ⇒ AWSCDK::CloudWatch::Metric
The interval, in milliseconds, between the time the Task starts and the time it closes.
-
#metric_schedule_time(props = nil) ⇒ AWSCDK::CloudWatch::Metric
The interval, in milliseconds, for which the activity stays in the schedule state.
-
#metric_scheduled(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Metric for the number of times this activity is scheduled.
-
#metric_started(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Metric for the number of times this activity is started.
-
#metric_succeeded(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Metric for the number of times this activity succeeds.
-
#metric_time(props = nil) ⇒ AWSCDK::CloudWatch::Metric
The interval, in milliseconds, between the time the activity is scheduled and the time it closes.
-
#metric_timed_out(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Metric for the number of times this activity times out.
-
#node ⇒ Constructs::Node
The tree node.
- #output_path ⇒ String?
- #outputs ⇒ Hash?
- #parameters ⇒ Hash?
- #processor ⇒ AWSCDK::StepFunctions::StateGraph?
- #processor=(value) ⇒ Object
- #processor_config ⇒ AWSCDK::StepFunctions::ProcessorConfig?
- #processor_config=(value) ⇒ Object
- #processor_mode ⇒ AWSCDK::StepFunctions::ProcessorMode?
- #processor_mode=(value) ⇒ Object
- #query_language ⇒ AWSCDK::StepFunctions::QueryLanguage?
-
#render_assign(top_level_query_language = nil) ⇒ Object
Render the assign in ASL JSON format.
-
#render_branches ⇒ Object
Render parallel branches in ASL JSON format.
-
#render_choices(top_level_query_language = nil) ⇒ Object
Render the choices in ASL JSON format.
-
#render_input_output ⇒ Object
Render InputPath/Parameters/OutputPath/Arguments/Output in ASL JSON format.
-
#render_item_processor ⇒ Object
Render ItemProcessor in ASL JSON format.
-
#render_iterator ⇒ Object
Render map iterator in ASL JSON format.
-
#render_next_end ⇒ Object
Render the default next state in ASL JSON format.
-
#render_query_language(top_level_query_language = nil) ⇒ Object
Render QueryLanguage in ASL JSON format if needed.
-
#render_result_selector ⇒ Object
Render ResultSelector in ASL JSON format.
-
#render_retry_catch(top_level_query_language = nil) ⇒ Object
Render error recovery options in ASL JSON format.
- #result_path ⇒ String?
- #result_selector ⇒ Hash?
-
#start_state ⇒ AWSCDK::StepFunctions::State
First state of this Chainable.
-
#state_id ⇒ String
Tokenized string that evaluates to the state's ID.
- #state_name ⇒ String?
- #task_metrics ⇒ AWSCDK::StepFunctions::TaskMetricsConfig?
- #task_policies ⇒ Array<AWSCDK::IAM::PolicyStatement>?
-
#to_state_json(top_level_query_language = nil) ⇒ Hash
Return the Amazon States Language object for this state.
-
#to_string ⇒ String
Returns a string representation of this construct.
-
#validate_state ⇒ Array<String>
Allows the state to validate itself.
-
#when_bound_to_graph(graph) ⇒ void
Called whenever this state is bound to a graph.
-
#with(*mixins) ⇒ Constructs::IConstruct
Applies one or more mixins to this construct.
Constructor Details
#initialize(scope, id, props) ⇒ EvaluateExpression
Returns a new instance of EvaluateExpression.
13 14 15 16 17 18 19 |
# File 'step_functions_tasks/evaluate_expression.rb', line 13 def initialize(scope, id, props) props = props.is_a?(Hash) ? ::AWSCDK::StepFunctionsTasks::EvaluateExpressionProps.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(scope, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJjb25zdHJ1Y3RzLkNvbnN0cnVjdCJ9")), "scope") Jsii::Type.check_type(id, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "id") Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9uc190YXNrcy5FdmFsdWF0ZUV4cHJlc3Npb25Qcm9wcyJ9")), "props") Jsii::Object.instance_method(:initialize).bind(self).call(scope, id, props) end |
Class Method Details
.jsii_overridable_methods ⇒ Object
21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 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 |
# File 'step_functions_tasks/evaluate_expression.rb', line 21 def self.jsii_overridable_methods { :node => { kind: :property, name: "node", is_optional: false }, :branches => { kind: :property, name: "branches", is_optional: false }, :end_states => { kind: :property, name: "endStates", is_optional: false }, :id => { kind: :property, name: "id", is_optional: false }, :start_state => { kind: :property, name: "startState", is_optional: false }, :state_id => { kind: :property, name: "stateId", is_optional: false }, :arguments => { kind: :property, name: "arguments", is_optional: true }, :assign => { kind: :property, name: "assign", is_optional: true }, :comment => { kind: :property, name: "comment", is_optional: true }, :input_path => { kind: :property, name: "inputPath", is_optional: true }, :output_path => { kind: :property, name: "outputPath", is_optional: true }, :outputs => { kind: :property, name: "outputs", is_optional: true }, :parameters => { kind: :property, name: "parameters", is_optional: true }, :query_language => { kind: :property, name: "queryLanguage", is_optional: true }, :result_path => { kind: :property, name: "resultPath", is_optional: true }, :result_selector => { kind: :property, name: "resultSelector", is_optional: true }, :state_name => { kind: :property, name: "stateName", is_optional: true }, :default_choice => { kind: :property, name: "defaultChoice", is_optional: true }, :iteration => { kind: :property, name: "iteration", is_optional: true }, :processor => { kind: :property, name: "processor", is_optional: true }, :processor_config => { kind: :property, name: "processorConfig", is_optional: true }, :processor_mode => { kind: :property, name: "processorMode", is_optional: true }, :task_metrics => { kind: :property, name: "taskMetrics", is_optional: true }, :task_policies => { kind: :property, name: "taskPolicies", is_optional: true }, :to_string => { kind: :method, name: "toString", is_optional: false }, :with => { kind: :method, name: "with", is_optional: false }, :add_branch => { kind: :method, name: "addBranch", is_optional: false }, :add_choice => { kind: :method, name: "addChoice", is_optional: false }, :add_item_processor => { kind: :method, name: "addItemProcessor", is_optional: false }, :add_iterator => { kind: :method, name: "addIterator", is_optional: false }, :add_prefix => { kind: :method, name: "addPrefix", is_optional: false }, :bind_to_graph => { kind: :method, name: "bindToGraph", is_optional: false }, :make_default => { kind: :method, name: "makeDefault", is_optional: false }, :make_next => { kind: :method, name: "makeNext", is_optional: false }, :render_assign => { kind: :method, name: "renderAssign", is_optional: false }, :render_branches => { kind: :method, name: "renderBranches", is_optional: false }, :render_choices => { kind: :method, name: "renderChoices", is_optional: false }, :render_input_output => { kind: :method, name: "renderInputOutput", is_optional: false }, :render_item_processor => { kind: :method, name: "renderItemProcessor", is_optional: false }, :render_iterator => { kind: :method, name: "renderIterator", is_optional: false }, :render_next_end => { kind: :method, name: "renderNextEnd", is_optional: false }, :render_query_language => { kind: :method, name: "renderQueryLanguage", is_optional: false }, :render_result_selector => { kind: :method, name: "renderResultSelector", is_optional: false }, :render_retry_catch => { kind: :method, name: "renderRetryCatch", is_optional: false }, :to_state_json => { kind: :method, name: "toStateJson", is_optional: false }, :validate_state => { kind: :method, name: "validateState", is_optional: false }, :when_bound_to_graph => { kind: :method, name: "whenBoundToGraph", is_optional: false }, :add_catch => { kind: :method, name: "addCatch", is_optional: false }, :add_retry => { kind: :method, name: "addRetry", is_optional: false }, :metric => { kind: :method, name: "metric", is_optional: false }, :metric_failed => { kind: :method, name: "metricFailed", is_optional: false }, :metric_heartbeat_timed_out => { kind: :method, name: "metricHeartbeatTimedOut", is_optional: false }, :metric_run_time => { kind: :method, name: "metricRunTime", is_optional: false }, :metric_scheduled => { kind: :method, name: "metricScheduled", is_optional: false }, :metric_schedule_time => { kind: :method, name: "metricScheduleTime", is_optional: false }, :metric_started => { kind: :method, name: "metricStarted", is_optional: false }, :metric_succeeded => { kind: :method, name: "metricSucceeded", is_optional: false }, :metric_time => { kind: :method, name: "metricTime", is_optional: false }, :metric_timed_out => { kind: :method, name: "metricTimedOut", is_optional: false }, :_next => { kind: :method, name: "next", is_optional: false }, } end |
Instance Method Details
#_next(_next) ⇒ AWSCDK::StepFunctions::Chain
Continue normal execution with the given state.
597 598 599 600 |
# File 'step_functions_tasks/evaluate_expression.rb', line 597 def _next(_next) Jsii::Type.check_type(_next, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5JQ2hhaW5hYmxlIn0=")), "next") jsii_call_method("next", [_next]) end |
#add_branch(branch) ⇒ void
This method returns an undefined value.
Add a parallel branch to this state.
269 270 271 272 |
# File 'step_functions_tasks/evaluate_expression.rb', line 269 def add_branch(branch) Jsii::Type.check_type(branch, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "branch") jsii_call_method("addBranch", [branch]) end |
#add_catch(handler, props = nil) ⇒ AWSCDK::StepFunctions::TaskStateBase
Add a recovery handler for this state.
When a particular error occurs, execution will continue at the error handler instead of failing the state machine execution.
461 462 463 464 465 466 |
# File 'step_functions_tasks/evaluate_expression.rb', line 461 def add_catch(handler, props = nil) Jsii::Type.check_type(handler, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5JQ2hhaW5hYmxlIn0=")), "handler") props = props.is_a?(Hash) ? ::AWSCDK::StepFunctions::CatchProps.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5DYXRjaFByb3BzIn0=")), "props") unless props.nil? jsii_call_method("addCatch", [handler, props]) end |
#add_choice(condition, _next, options = nil) ⇒ void
This method returns an undefined value.
Add a choice branch to this state.
280 281 282 283 284 285 286 |
# File 'step_functions_tasks/evaluate_expression.rb', line 280 def add_choice(condition, _next, = nil) Jsii::Type.check_type(condition, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5Db25kaXRpb24ifQ==")), "condition") Jsii::Type.check_type(_next, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZSJ9")), "next") = .is_a?(Hash) ? ::AWSCDK::StepFunctions::ChoiceTransitionOptions.new(**.transform_keys(&:to_sym)) : Jsii::Type.check_type(, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5DaG9pY2VUcmFuc2l0aW9uT3B0aW9ucyJ9")), "options") unless .nil? jsii_call_method("addChoice", [condition, _next, ]) end |
#add_item_processor(processor, config = nil) ⇒ void
This method returns an undefined value.
Add a item processor to this state.
293 294 295 296 297 298 |
# File 'step_functions_tasks/evaluate_expression.rb', line 293 def add_item_processor(processor, config = nil) Jsii::Type.check_type(processor, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "processor") config = config.is_a?(Hash) ? ::AWSCDK::StepFunctions::ProcessorConfig.new(**config.transform_keys(&:to_sym)) : config Jsii::Type.check_type(config, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5Qcm9jZXNzb3JDb25maWcifQ==")), "config") unless config.nil? jsii_call_method("addItemProcessor", [processor, config]) end |
#add_iterator(iteration) ⇒ void
This method returns an undefined value.
Add a map iterator to this state.
304 305 306 307 |
# File 'step_functions_tasks/evaluate_expression.rb', line 304 def add_iterator(iteration) Jsii::Type.check_type(iteration, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "iteration") jsii_call_method("addIterator", [iteration]) end |
#add_prefix(x) ⇒ void
This method returns an undefined value.
Add a prefix to the stateId of this state.
313 314 315 316 |
# File 'step_functions_tasks/evaluate_expression.rb', line 313 def add_prefix(x) Jsii::Type.check_type(x, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "x") jsii_call_method("addPrefix", [x]) end |
#add_retry(props = nil) ⇒ AWSCDK::StepFunctions::TaskStateBase
Add retry configuration for this state.
This controls if and how the execution will be retried if a particular error occurs.
475 476 477 478 479 |
# File 'step_functions_tasks/evaluate_expression.rb', line 475 def add_retry(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::StepFunctions::RetryProps.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5SZXRyeVByb3BzIn0=")), "props") unless props.nil? jsii_call_method("addRetry", [props]) end |
#arguments ⇒ Hash?
127 128 129 |
# File 'step_functions_tasks/evaluate_expression.rb', line 127 def arguments() jsii_get_property("arguments") end |
#assign ⇒ Hash?
132 133 134 |
# File 'step_functions_tasks/evaluate_expression.rb', line 132 def assign() jsii_get_property("assign") end |
#bind_to_graph(graph) ⇒ void
This method returns an undefined value.
Register this state as part of the given graph.
Don't call this. It will be called automatically when you work with states normally.
325 326 327 328 |
# File 'step_functions_tasks/evaluate_expression.rb', line 325 def bind_to_graph(graph) Jsii::Type.check_type(graph, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "graph") jsii_call_method("bindToGraph", [graph]) end |
#branches ⇒ Array<AWSCDK::StepFunctions::StateGraph>
94 95 96 |
# File 'step_functions_tasks/evaluate_expression.rb', line 94 def branches() jsii_get_property("branches") end |
#comment ⇒ String?
137 138 139 |
# File 'step_functions_tasks/evaluate_expression.rb', line 137 def comment() jsii_get_property("comment") end |
#default_choice ⇒ AWSCDK::StepFunctions::State?
182 183 184 |
# File 'step_functions_tasks/evaluate_expression.rb', line 182 def default_choice() jsii_get_property("defaultChoice") end |
#default_choice=(value) ⇒ Object
186 187 188 189 |
# File 'step_functions_tasks/evaluate_expression.rb', line 186 def default_choice=(value) Jsii::Type.check_type(value, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZSJ9")), "defaultChoice") unless value.nil? jsii_set_property("defaultChoice", value) end |
#end_states ⇒ Array<AWSCDK::StepFunctions::INextable>
Continuable states of this Chainable.
101 102 103 |
# File 'step_functions_tasks/evaluate_expression.rb', line 101 def end_states() jsii_get_property("endStates") end |
#id ⇒ String
Descriptive identifier for this chainable.
108 109 110 |
# File 'step_functions_tasks/evaluate_expression.rb', line 108 def id() jsii_get_property("id") end |
#input_path ⇒ String?
142 143 144 |
# File 'step_functions_tasks/evaluate_expression.rb', line 142 def input_path() jsii_get_property("inputPath") end |
#iteration ⇒ AWSCDK::StepFunctions::StateGraph?
192 193 194 |
# File 'step_functions_tasks/evaluate_expression.rb', line 192 def iteration() jsii_get_property("iteration") end |
#iteration=(value) ⇒ Object
196 197 198 199 |
# File 'step_functions_tasks/evaluate_expression.rb', line 196 def iteration=(value) Jsii::Type.check_type(value, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "iteration") unless value.nil? jsii_set_property("iteration", value) end |
#make_default(_def) ⇒ void
This method returns an undefined value.
Make the indicated state the default choice transition of this state.
334 335 336 337 |
# File 'step_functions_tasks/evaluate_expression.rb', line 334 def make_default(_def) Jsii::Type.check_type(_def, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZSJ9")), "def") jsii_call_method("makeDefault", [_def]) end |
#make_next(_next) ⇒ void
This method returns an undefined value.
Make the indicated state the default transition of this state.
343 344 345 346 |
# File 'step_functions_tasks/evaluate_expression.rb', line 343 def make_next(_next) Jsii::Type.check_type(_next, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZSJ9")), "next") jsii_call_method("makeNext", [_next]) end |
#metric(metric_name, props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Return the given named metric for this Task.
487 488 489 490 491 492 |
# File 'step_functions_tasks/evaluate_expression.rb', line 487 def metric(metric_name, props = nil) Jsii::Type.check_type(metric_name, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "metricName") props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metric", [metric_name, props]) end |
#metric_failed(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Metric for the number of times this activity fails.
499 500 501 502 503 |
# File 'step_functions_tasks/evaluate_expression.rb', line 499 def metric_failed(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricFailed", [props]) end |
#metric_heartbeat_timed_out(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Metric for the number of times the heartbeat times out for this activity.
510 511 512 513 514 |
# File 'step_functions_tasks/evaluate_expression.rb', line 510 def metric_heartbeat_timed_out(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricHeartbeatTimedOut", [props]) end |
#metric_run_time(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - average over 5 minutes
The interval, in milliseconds, between the time the Task starts and the time it closes.
521 522 523 524 525 |
# File 'step_functions_tasks/evaluate_expression.rb', line 521 def metric_run_time(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricRunTime", [props]) end |
#metric_schedule_time(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - average over 5 minutes
The interval, in milliseconds, for which the activity stays in the schedule state.
543 544 545 546 547 |
# File 'step_functions_tasks/evaluate_expression.rb', line 543 def metric_schedule_time(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricScheduleTime", [props]) end |
#metric_scheduled(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Metric for the number of times this activity is scheduled.
532 533 534 535 536 |
# File 'step_functions_tasks/evaluate_expression.rb', line 532 def metric_scheduled(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricScheduled", [props]) end |
#metric_started(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Metric for the number of times this activity is started.
554 555 556 557 558 |
# File 'step_functions_tasks/evaluate_expression.rb', line 554 def metric_started(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricStarted", [props]) end |
#metric_succeeded(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Metric for the number of times this activity succeeds.
565 566 567 568 569 |
# File 'step_functions_tasks/evaluate_expression.rb', line 565 def metric_succeeded(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricSucceeded", [props]) end |
#metric_time(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - average over 5 minutes
The interval, in milliseconds, between the time the activity is scheduled and the time it closes.
576 577 578 579 580 |
# File 'step_functions_tasks/evaluate_expression.rb', line 576 def metric_time(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricTime", [props]) end |
#metric_timed_out(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Metric for the number of times this activity times out.
587 588 589 590 591 |
# File 'step_functions_tasks/evaluate_expression.rb', line 587 def metric_timed_out(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricTimedOut", [props]) end |
#node ⇒ Constructs::Node
The tree node.
89 90 91 |
# File 'step_functions_tasks/evaluate_expression.rb', line 89 def node() jsii_get_property("node") end |
#output_path ⇒ String?
147 148 149 |
# File 'step_functions_tasks/evaluate_expression.rb', line 147 def output_path() jsii_get_property("outputPath") end |
#outputs ⇒ Hash?
152 153 154 |
# File 'step_functions_tasks/evaluate_expression.rb', line 152 def outputs() jsii_get_property("outputs") end |
#parameters ⇒ Hash?
157 158 159 |
# File 'step_functions_tasks/evaluate_expression.rb', line 157 def parameters() jsii_get_property("parameters") end |
#processor ⇒ AWSCDK::StepFunctions::StateGraph?
202 203 204 |
# File 'step_functions_tasks/evaluate_expression.rb', line 202 def processor() jsii_get_property("processor") end |
#processor=(value) ⇒ Object
206 207 208 209 |
# File 'step_functions_tasks/evaluate_expression.rb', line 206 def processor=(value) Jsii::Type.check_type(value, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "processor") unless value.nil? jsii_set_property("processor", value) end |
#processor_config ⇒ AWSCDK::StepFunctions::ProcessorConfig?
212 213 214 |
# File 'step_functions_tasks/evaluate_expression.rb', line 212 def processor_config() jsii_get_property("processorConfig") end |
#processor_config=(value) ⇒ Object
216 217 218 219 220 |
# File 'step_functions_tasks/evaluate_expression.rb', line 216 def processor_config=(value) value = value.is_a?(Hash) ? ::AWSCDK::StepFunctions::ProcessorConfig.new(**value.transform_keys(&:to_sym)) : value Jsii::Type.check_type(value, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5Qcm9jZXNzb3JDb25maWcifQ==")), "processorConfig") unless value.nil? jsii_set_property("processorConfig", value) end |
#processor_mode ⇒ AWSCDK::StepFunctions::ProcessorMode?
223 224 225 |
# File 'step_functions_tasks/evaluate_expression.rb', line 223 def processor_mode() jsii_get_property("processorMode") end |
#processor_mode=(value) ⇒ Object
227 228 229 230 |
# File 'step_functions_tasks/evaluate_expression.rb', line 227 def processor_mode=(value) Jsii::Type.check_type(value, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5Qcm9jZXNzb3JNb2RlIn0=")), "processorMode") unless value.nil? jsii_set_property("processorMode", value) end |
#query_language ⇒ AWSCDK::StepFunctions::QueryLanguage?
162 163 164 |
# File 'step_functions_tasks/evaluate_expression.rb', line 162 def query_language() jsii_get_property("queryLanguage") end |
#render_assign(top_level_query_language = nil) ⇒ Object
Render the assign in ASL JSON format.
352 353 354 355 |
# File 'step_functions_tasks/evaluate_expression.rb', line 352 def render_assign(top_level_query_language = nil) Jsii::Type.check_type(top_level_query_language, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5RdWVyeUxhbmd1YWdlIn0=")), "topLevelQueryLanguage") unless top_level_query_language.nil? jsii_call_method("renderAssign", [top_level_query_language]) end |
#render_branches ⇒ Object
Render parallel branches in ASL JSON format.
360 361 362 |
# File 'step_functions_tasks/evaluate_expression.rb', line 360 def render_branches() jsii_call_method("renderBranches", []) end |
#render_choices(top_level_query_language = nil) ⇒ Object
Render the choices in ASL JSON format.
368 369 370 371 |
# File 'step_functions_tasks/evaluate_expression.rb', line 368 def render_choices(top_level_query_language = nil) Jsii::Type.check_type(top_level_query_language, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5RdWVyeUxhbmd1YWdlIn0=")), "topLevelQueryLanguage") unless top_level_query_language.nil? jsii_call_method("renderChoices", [top_level_query_language]) end |
#render_input_output ⇒ Object
Render InputPath/Parameters/OutputPath/Arguments/Output in ASL JSON format.
376 377 378 |
# File 'step_functions_tasks/evaluate_expression.rb', line 376 def render_input_output() jsii_call_method("renderInputOutput", []) end |
#render_item_processor ⇒ Object
Render ItemProcessor in ASL JSON format.
383 384 385 |
# File 'step_functions_tasks/evaluate_expression.rb', line 383 def render_item_processor() jsii_call_method("renderItemProcessor", []) end |
#render_iterator ⇒ Object
Render map iterator in ASL JSON format.
390 391 392 |
# File 'step_functions_tasks/evaluate_expression.rb', line 390 def render_iterator() jsii_call_method("renderIterator", []) end |
#render_next_end ⇒ Object
Render the default next state in ASL JSON format.
397 398 399 |
# File 'step_functions_tasks/evaluate_expression.rb', line 397 def render_next_end() jsii_call_method("renderNextEnd", []) end |
#render_query_language(top_level_query_language = nil) ⇒ Object
Render QueryLanguage in ASL JSON format if needed.
405 406 407 408 |
# File 'step_functions_tasks/evaluate_expression.rb', line 405 def render_query_language(top_level_query_language = nil) Jsii::Type.check_type(top_level_query_language, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5RdWVyeUxhbmd1YWdlIn0=")), "topLevelQueryLanguage") unless top_level_query_language.nil? jsii_call_method("renderQueryLanguage", [top_level_query_language]) end |
#render_result_selector ⇒ Object
Render ResultSelector in ASL JSON format.
413 414 415 |
# File 'step_functions_tasks/evaluate_expression.rb', line 413 def render_result_selector() jsii_call_method("renderResultSelector", []) end |
#render_retry_catch(top_level_query_language = nil) ⇒ Object
Render error recovery options in ASL JSON format.
421 422 423 424 |
# File 'step_functions_tasks/evaluate_expression.rb', line 421 def render_retry_catch(top_level_query_language = nil) Jsii::Type.check_type(top_level_query_language, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5RdWVyeUxhbmd1YWdlIn0=")), "topLevelQueryLanguage") unless top_level_query_language.nil? jsii_call_method("renderRetryCatch", [top_level_query_language]) end |
#result_path ⇒ String?
167 168 169 |
# File 'step_functions_tasks/evaluate_expression.rb', line 167 def result_path() jsii_get_property("resultPath") end |
#result_selector ⇒ Hash?
172 173 174 |
# File 'step_functions_tasks/evaluate_expression.rb', line 172 def result_selector() jsii_get_property("resultSelector") end |
#start_state ⇒ AWSCDK::StepFunctions::State
First state of this Chainable.
115 116 117 |
# File 'step_functions_tasks/evaluate_expression.rb', line 115 def start_state() jsii_get_property("startState") end |
#state_id ⇒ String
Tokenized string that evaluates to the state's ID.
122 123 124 |
# File 'step_functions_tasks/evaluate_expression.rb', line 122 def state_id() jsii_get_property("stateId") end |
#state_name ⇒ String?
177 178 179 |
# File 'step_functions_tasks/evaluate_expression.rb', line 177 def state_name() jsii_get_property("stateName") end |
#task_metrics ⇒ AWSCDK::StepFunctions::TaskMetricsConfig?
233 234 235 |
# File 'step_functions_tasks/evaluate_expression.rb', line 233 def task_metrics() jsii_get_property("taskMetrics") end |
#task_policies ⇒ Array<AWSCDK::IAM::PolicyStatement>?
238 239 240 |
# File 'step_functions_tasks/evaluate_expression.rb', line 238 def task_policies() jsii_get_property("taskPolicies") end |
#to_state_json(top_level_query_language = nil) ⇒ Hash
Return the Amazon States Language object for this state.
430 431 432 433 |
# File 'step_functions_tasks/evaluate_expression.rb', line 430 def to_state_json(top_level_query_language = nil) Jsii::Type.check_type(top_level_query_language, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5RdWVyeUxhbmd1YWdlIn0=")), "topLevelQueryLanguage") unless top_level_query_language.nil? jsii_call_method("toStateJson", [top_level_query_language]) end |
#to_string ⇒ String
Returns a string representation of this construct.
245 246 247 |
# File 'step_functions_tasks/evaluate_expression.rb', line 245 def to_string() jsii_call_method("toString", []) end |
#validate_state ⇒ Array<String>
Allows the state to validate itself.
438 439 440 |
# File 'step_functions_tasks/evaluate_expression.rb', line 438 def validate_state() jsii_call_method("validateState", []) end |
#when_bound_to_graph(graph) ⇒ void
This method returns an undefined value.
Called whenever this state is bound to a graph.
Can be overridden by subclasses.
448 449 450 451 |
# File 'step_functions_tasks/evaluate_expression.rb', line 448 def when_bound_to_graph(graph) Jsii::Type.check_type(graph, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "graph") jsii_call_method("whenBoundToGraph", [graph]) end |
#with(*mixins) ⇒ Constructs::IConstruct
Applies one or more mixins to this construct.
Mixins are applied in order. The list of constructs is captured at the
start of the call, so constructs added by a mixin will not be visited.
Use multiple with() calls if subsequent mixins should apply to added
constructs.
258 259 260 261 262 263 |
# File 'step_functions_tasks/evaluate_expression.rb', line 258 def with(*mixins) mixins.each_with_index do |item, index| Jsii::Type.check_type(item, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJjb25zdHJ1Y3RzLklNaXhpbiJ9")), "mixins[#{index}]") end jsii_call_method("with", [*mixins]) end |