lib/aws-sdk-glue/client.rb in aws-sdk-glue-1.66.0 vs lib/aws-sdk-glue/client.rb in aws-sdk-glue-1.67.0
- old
+ new
@@ -1001,11 +1001,12 @@
# resp.workflows[0].last_run.previous_run_id #=> String
# resp.workflows[0].last_run.workflow_run_properties #=> Hash
# resp.workflows[0].last_run.workflow_run_properties["IdString"] #=> String
# resp.workflows[0].last_run.started_on #=> Time
# resp.workflows[0].last_run.completed_on #=> Time
- # resp.workflows[0].last_run.status #=> String, one of "RUNNING", "COMPLETED", "STOPPING", "STOPPED"
+ # resp.workflows[0].last_run.status #=> String, one of "RUNNING", "COMPLETED", "STOPPING", "STOPPED", "ERROR"
+ # resp.workflows[0].last_run.error_message #=> String
# resp.workflows[0].last_run.statistics.total_actions #=> Integer
# resp.workflows[0].last_run.statistics.timeout_actions #=> Integer
# resp.workflows[0].last_run.statistics.failed_actions #=> Integer
# resp.workflows[0].last_run.statistics.stopped_actions #=> Integer
# resp.workflows[0].last_run.statistics.succeeded_actions #=> Integer
@@ -1132,10 +1133,11 @@
# resp.workflows[0].graph.nodes[0].crawler_details.crawls[0].log_group #=> String
# resp.workflows[0].graph.nodes[0].crawler_details.crawls[0].log_stream #=> String
# resp.workflows[0].graph.edges #=> Array
# resp.workflows[0].graph.edges[0].source_id #=> String
# resp.workflows[0].graph.edges[0].destination_id #=> String
+ # resp.workflows[0].max_concurrent_runs #=> Integer
# resp.missing_workflows #=> Array
# resp.missing_workflows[0] #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/BatchGetWorkflows AWS API Documentation
#
@@ -2560,10 +2562,17 @@
# workflow.
#
# @option params [Hash<String,String>] :tags
# The tags to be used with this workflow.
#
+ # @option params [Integer] :max_concurrent_runs
+ # You can use this parameter to prevent unwanted multiple updates to
+ # data, to control costs, or in some cases, to prevent exceeding the
+ # maximum number of concurrent runs of any of the component jobs. If you
+ # leave this parameter blank, there is no limit to the number of
+ # concurrent workflow runs.
+ #
# @return [Types::CreateWorkflowResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
#
# * {Types::CreateWorkflowResponse#name #name} => String
#
# @example Request syntax with placeholder values
@@ -2575,10 +2584,11 @@
# "IdString" => "GenericString",
# },
# tags: {
# "TagKey" => "TagValue",
# },
+ # max_concurrent_runs: 1,
# })
#
# @example Response structure
#
# resp.name #=> String
@@ -5963,11 +5973,12 @@
# resp.workflow.last_run.previous_run_id #=> String
# resp.workflow.last_run.workflow_run_properties #=> Hash
# resp.workflow.last_run.workflow_run_properties["IdString"] #=> String
# resp.workflow.last_run.started_on #=> Time
# resp.workflow.last_run.completed_on #=> Time
- # resp.workflow.last_run.status #=> String, one of "RUNNING", "COMPLETED", "STOPPING", "STOPPED"
+ # resp.workflow.last_run.status #=> String, one of "RUNNING", "COMPLETED", "STOPPING", "STOPPED", "ERROR"
+ # resp.workflow.last_run.error_message #=> String
# resp.workflow.last_run.statistics.total_actions #=> Integer
# resp.workflow.last_run.statistics.timeout_actions #=> Integer
# resp.workflow.last_run.statistics.failed_actions #=> Integer
# resp.workflow.last_run.statistics.stopped_actions #=> Integer
# resp.workflow.last_run.statistics.succeeded_actions #=> Integer
@@ -6094,10 +6105,11 @@
# resp.workflow.graph.nodes[0].crawler_details.crawls[0].log_group #=> String
# resp.workflow.graph.nodes[0].crawler_details.crawls[0].log_stream #=> String
# resp.workflow.graph.edges #=> Array
# resp.workflow.graph.edges[0].source_id #=> String
# resp.workflow.graph.edges[0].destination_id #=> String
+ # resp.workflow.max_concurrent_runs #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetWorkflow AWS API Documentation
#
# @overload get_workflow(params = {})
# @param [Hash] params ({})
@@ -6136,11 +6148,12 @@
# resp.run.previous_run_id #=> String
# resp.run.workflow_run_properties #=> Hash
# resp.run.workflow_run_properties["IdString"] #=> String
# resp.run.started_on #=> Time
# resp.run.completed_on #=> Time
- # resp.run.status #=> String, one of "RUNNING", "COMPLETED", "STOPPING", "STOPPED"
+ # resp.run.status #=> String, one of "RUNNING", "COMPLETED", "STOPPING", "STOPPED", "ERROR"
+ # resp.run.error_message #=> String
# resp.run.statistics.total_actions #=> Integer
# resp.run.statistics.timeout_actions #=> Integer
# resp.run.statistics.failed_actions #=> Integer
# resp.run.statistics.stopped_actions #=> Integer
# resp.run.statistics.succeeded_actions #=> Integer
@@ -6288,11 +6301,12 @@
# resp.runs[0].previous_run_id #=> String
# resp.runs[0].workflow_run_properties #=> Hash
# resp.runs[0].workflow_run_properties["IdString"] #=> String
# resp.runs[0].started_on #=> Time
# resp.runs[0].completed_on #=> Time
- # resp.runs[0].status #=> String, one of "RUNNING", "COMPLETED", "STOPPING", "STOPPED"
+ # resp.runs[0].status #=> String, one of "RUNNING", "COMPLETED", "STOPPING", "STOPPED", "ERROR"
+ # resp.runs[0].error_message #=> String
# resp.runs[0].statistics.total_actions #=> Integer
# resp.runs[0].statistics.timeout_actions #=> Integer
# resp.runs[0].statistics.failed_actions #=> Integer
# resp.runs[0].statistics.stopped_actions #=> Integer
# resp.runs[0].statistics.succeeded_actions #=> Integer
@@ -6886,23 +6900,23 @@
def reset_job_bookmark(params = {}, options = {})
req = build_request(:reset_job_bookmark, params)
req.send_request(options)
end
- # Restarts any completed nodes in a workflow run and resumes the run
- # execution.
+ # Restarts selected nodes of a previous partially completed workflow run
+ # and resumes the workflow run. The selected nodes and all nodes that
+ # are downstream from the selected nodes are run.
#
# @option params [required, String] :name
# The name of the workflow to resume.
#
# @option params [required, String] :run_id
# The ID of the workflow run to resume.
#
# @option params [required, Array<String>] :node_ids
# A list of the node IDs for the nodes you want to restart. The nodes
- # that are to be restarted must have an execution attempt in the
- # original run.
+ # that are to be restarted must have a run attempt in the original run.
#
# @return [Types::ResumeWorkflowRunResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
#
# * {Types::ResumeWorkflowRunResponse#run_id #run_id} => String
# * {Types::ResumeWorkflowRunResponse#node_ids #node_ids} => Array<String>
@@ -8848,10 +8862,17 @@
#
# @option params [Hash<String,String>] :default_run_properties
# A collection of properties to be used as part of each execution of the
# workflow.
#
+ # @option params [Integer] :max_concurrent_runs
+ # You can use this parameter to prevent unwanted multiple updates to
+ # data, to control costs, or in some cases, to prevent exceeding the
+ # maximum number of concurrent runs of any of the component jobs. If you
+ # leave this parameter blank, there is no limit to the number of
+ # concurrent workflow runs.
+ #
# @return [Types::UpdateWorkflowResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
#
# * {Types::UpdateWorkflowResponse#name #name} => String
#
# @example Request syntax with placeholder values
@@ -8860,10 +8881,11 @@
# name: "NameString", # required
# description: "GenericString",
# default_run_properties: {
# "IdString" => "GenericString",
# },
+ # max_concurrent_runs: 1,
# })
#
# @example Response structure
#
# resp.name #=> String
@@ -8888,10 +8910,10 @@
operation: config.api.operation(operation_name),
client: self,
params: params,
config: config)
context[:gem_name] = 'aws-sdk-glue'
- context[:gem_version] = '1.66.0'
+ context[:gem_version] = '1.67.0'
Seahorse::Client::Request.new(handlers, context)
end
# @api private
# @deprecated