lib/aws-sdk-glue/client.rb in aws-sdk-glue-1.172.0 vs lib/aws-sdk-glue/client.rb in aws-sdk-glue-1.175.0
- old
+ new
@@ -299,12 +299,13 @@
# in the future.
#
#
# @option options [String] :sdk_ua_app_id
# A unique and opaque application ID that is appended to the
- # User-Agent header as app/<sdk_ua_app_id>. It should have a
- # maximum length of 50.
+ # User-Agent header as app/sdk_ua_app_id. It should have a
+ # maximum length of 50. This variable is sourced from environment
+ # variable AWS_SDK_UA_APP_ID or the shared config profile attribute sdk_ua_app_id.
#
# @option options [String] :secret_access_key
#
# @option options [String] :session_token
#
@@ -1086,10 +1087,11 @@
#
# @example Response structure
#
# resp.jobs #=> Array
# resp.jobs[0].name #=> String
+ # resp.jobs[0].job_mode #=> String, one of "SCRIPT", "VISUAL", "NOTEBOOK"
# resp.jobs[0].description #=> String
# resp.jobs[0].log_uri #=> String
# resp.jobs[0].role #=> String
# resp.jobs[0].created_on #=> Time
# resp.jobs[0].last_modified_on #=> Time
@@ -1966,10 +1968,11 @@
# resp.jobs[0].source_control_details.branch #=> String
# resp.jobs[0].source_control_details.folder #=> String
# resp.jobs[0].source_control_details.last_commit_id #=> String
# resp.jobs[0].source_control_details.auth_strategy #=> String, one of "PERSONAL_ACCESS_TOKEN", "AWS_SECRETS_MANAGER"
# resp.jobs[0].source_control_details.auth_token #=> String
+ # resp.jobs[0].maintenance_window #=> String
# resp.jobs_not_found #=> Array
# resp.jobs_not_found[0] #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/BatchGetJobs AWS API Documentation
#
@@ -2175,11 +2178,11 @@
# resp.triggers[0].actions[0].crawler_name #=> String
# resp.triggers[0].predicate.logical #=> String, one of "AND", "ANY"
# resp.triggers[0].predicate.conditions #=> Array
# resp.triggers[0].predicate.conditions[0].logical_operator #=> String, one of "EQUALS"
# resp.triggers[0].predicate.conditions[0].job_name #=> String
- # resp.triggers[0].predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.triggers[0].predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.triggers[0].predicate.conditions[0].crawler_name #=> String
# resp.triggers[0].predicate.conditions[0].crawl_state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.triggers[0].event_batching_condition.batch_size #=> Integer
# resp.triggers[0].event_batching_condition.batch_window #=> Integer
# resp.triggers_not_found #=> Array
@@ -2267,25 +2270,26 @@
# resp.workflows[0].last_run.graph.nodes[0].trigger_details.trigger.actions[0].crawler_name #=> String
# resp.workflows[0].last_run.graph.nodes[0].trigger_details.trigger.predicate.logical #=> String, one of "AND", "ANY"
# resp.workflows[0].last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions #=> Array
# resp.workflows[0].last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].logical_operator #=> String, one of "EQUALS"
# resp.workflows[0].last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].job_name #=> String
- # resp.workflows[0].last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.workflows[0].last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.workflows[0].last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].crawler_name #=> String
# resp.workflows[0].last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].crawl_state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.workflows[0].last_run.graph.nodes[0].trigger_details.trigger.event_batching_condition.batch_size #=> Integer
# resp.workflows[0].last_run.graph.nodes[0].trigger_details.trigger.event_batching_condition.batch_window #=> Integer
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs #=> Array
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].id #=> String
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].attempt #=> Integer
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].previous_run_id #=> String
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].trigger_name #=> String
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].job_name #=> String
+ # resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].job_mode #=> String, one of "SCRIPT", "VISUAL", "NOTEBOOK"
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].started_on #=> Time
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].last_modified_on #=> Time
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].completed_on #=> Time
- # resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].arguments #=> Hash
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].arguments["GenericString"] #=> String
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].error_message #=> String
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].predecessor_runs #=> Array
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].predecessor_runs[0].job_name #=> String
@@ -2300,10 +2304,11 @@
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].log_group_name #=> String
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].glue_version #=> String
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].dpu_seconds #=> Float
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
+ # resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].maintenance_window #=> String
# resp.workflows[0].last_run.graph.nodes[0].crawler_details.crawls #=> Array
# resp.workflows[0].last_run.graph.nodes[0].crawler_details.crawls[0].state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.workflows[0].last_run.graph.nodes[0].crawler_details.crawls[0].started_on #=> Time
# resp.workflows[0].last_run.graph.nodes[0].crawler_details.crawls[0].completed_on #=> Time
# resp.workflows[0].last_run.graph.nodes[0].crawler_details.crawls[0].error_message #=> String
@@ -2335,25 +2340,26 @@
# resp.workflows[0].graph.nodes[0].trigger_details.trigger.actions[0].crawler_name #=> String
# resp.workflows[0].graph.nodes[0].trigger_details.trigger.predicate.logical #=> String, one of "AND", "ANY"
# resp.workflows[0].graph.nodes[0].trigger_details.trigger.predicate.conditions #=> Array
# resp.workflows[0].graph.nodes[0].trigger_details.trigger.predicate.conditions[0].logical_operator #=> String, one of "EQUALS"
# resp.workflows[0].graph.nodes[0].trigger_details.trigger.predicate.conditions[0].job_name #=> String
- # resp.workflows[0].graph.nodes[0].trigger_details.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.workflows[0].graph.nodes[0].trigger_details.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.workflows[0].graph.nodes[0].trigger_details.trigger.predicate.conditions[0].crawler_name #=> String
# resp.workflows[0].graph.nodes[0].trigger_details.trigger.predicate.conditions[0].crawl_state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.workflows[0].graph.nodes[0].trigger_details.trigger.event_batching_condition.batch_size #=> Integer
# resp.workflows[0].graph.nodes[0].trigger_details.trigger.event_batching_condition.batch_window #=> Integer
# resp.workflows[0].graph.nodes[0].job_details.job_runs #=> Array
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].id #=> String
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].attempt #=> Integer
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].previous_run_id #=> String
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].trigger_name #=> String
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].job_name #=> String
+ # resp.workflows[0].graph.nodes[0].job_details.job_runs[0].job_mode #=> String, one of "SCRIPT", "VISUAL", "NOTEBOOK"
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].started_on #=> Time
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].last_modified_on #=> Time
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].completed_on #=> Time
- # resp.workflows[0].graph.nodes[0].job_details.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.workflows[0].graph.nodes[0].job_details.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].arguments #=> Hash
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].arguments["GenericString"] #=> String
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].error_message #=> String
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].predecessor_runs #=> Array
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].predecessor_runs[0].job_name #=> String
@@ -2368,10 +2374,11 @@
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].log_group_name #=> String
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].glue_version #=> String
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].dpu_seconds #=> Float
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
+ # resp.workflows[0].graph.nodes[0].job_details.job_runs[0].maintenance_window #=> String
# resp.workflows[0].graph.nodes[0].crawler_details.crawls #=> Array
# resp.workflows[0].graph.nodes[0].crawler_details.crawls[0].state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.workflows[0].graph.nodes[0].crawler_details.crawls[0].started_on #=> Time
# resp.workflows[0].graph.nodes[0].crawler_details.crawls[0].completed_on #=> Time
# resp.workflows[0].graph.nodes[0].crawler_details.crawls[0].error_message #=> String
@@ -3411,10 +3418,23 @@
#
# @option params [required, String] :name
# The name you assign to this job definition. It must be unique in your
# account.
#
+ # @option params [String] :job_mode
+ # A mode that describes how a job was created. Valid values are:
+ #
+ # * `SCRIPT` - The job was created using the Glue Studio script editor.
+ #
+ # * `VISUAL` - The job was created using the Glue Studio visual editor.
+ #
+ # * `NOTEBOOK` - The job was created using an interactive sessions
+ # notebook.
+ #
+ # When the `JobMode` field is missing or null, `SCRIPT` is assigned as
+ # the default value.
+ #
# @option params [String] :description
# Description of the job being defined.
#
# @option params [String] :log_uri
# This field is reserved for future use.
@@ -3623,10 +3643,21 @@
#
# @option params [Types::SourceControlDetails] :source_control_details
# The details for a source control configuration for a job, allowing
# synchronization of job artifacts to or from a remote repository.
#
+ # @option params [String] :maintenance_window
+ # This field specifies a day of the week and hour for a maintenance
+ # window for streaming jobs. Glue periodically performs maintenance
+ # activities. During these maintenance windows, Glue will need to
+ # restart your streaming jobs.
+ #
+ # Glue will restart the job within 3 hours of the specified maintenance
+ # window. For instance, if you set up the maintenance window for Monday
+ # at 10:00AM GMT, your jobs will be restarted between 10:00AM GMT to
+ # 1:00PM GMT.
+ #
# @return [Types::CreateJobResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
#
# * {Types::CreateJobResponse#name #name} => String
#
# @example Response structure
@@ -4709,11 +4740,11 @@
# logical: "AND", # accepts AND, ANY
# conditions: [
# {
# logical_operator: "EQUALS", # accepts EQUALS
# job_name: "NameString",
- # state: "STARTING", # accepts STARTING, RUNNING, STOPPING, STOPPED, SUCCEEDED, FAILED, TIMEOUT, ERROR, WAITING
+ # state: "STARTING", # accepts STARTING, RUNNING, STOPPING, STOPPED, SUCCEEDED, FAILED, TIMEOUT, ERROR, WAITING, EXPIRED
# crawler_name: "NameString",
# crawl_state: "RUNNING", # accepts RUNNING, CANCELLING, CANCELLED, SUCCEEDED, FAILED, ERROR
# },
# ],
# },
@@ -7317,10 +7348,11 @@
# })
#
# @example Response structure
#
# resp.job.name #=> String
+ # resp.job.job_mode #=> String, one of "SCRIPT", "VISUAL", "NOTEBOOK"
# resp.job.description #=> String
# resp.job.log_uri #=> String
# resp.job.role #=> String
# resp.job.created_on #=> Time
# resp.job.last_modified_on #=> Time
@@ -8197,10 +8229,11 @@
# resp.job.source_control_details.branch #=> String
# resp.job.source_control_details.folder #=> String
# resp.job.source_control_details.last_commit_id #=> String
# resp.job.source_control_details.auth_strategy #=> String, one of "PERSONAL_ACCESS_TOKEN", "AWS_SECRETS_MANAGER"
# resp.job.source_control_details.auth_token #=> String
+ # resp.job.maintenance_window #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetJob AWS API Documentation
#
# @overload get_job(params = {})
# @param [Hash] params ({})
@@ -8289,14 +8322,15 @@
# resp.job_run.id #=> String
# resp.job_run.attempt #=> Integer
# resp.job_run.previous_run_id #=> String
# resp.job_run.trigger_name #=> String
# resp.job_run.job_name #=> String
+ # resp.job_run.job_mode #=> String, one of "SCRIPT", "VISUAL", "NOTEBOOK"
# resp.job_run.started_on #=> Time
# resp.job_run.last_modified_on #=> Time
# resp.job_run.completed_on #=> Time
- # resp.job_run.job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.job_run.job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.job_run.arguments #=> Hash
# resp.job_run.arguments["GenericString"] #=> String
# resp.job_run.error_message #=> String
# resp.job_run.predecessor_runs #=> Array
# resp.job_run.predecessor_runs[0].job_name #=> String
@@ -8311,10 +8345,11 @@
# resp.job_run.log_group_name #=> String
# resp.job_run.notification_property.notify_delay_after #=> Integer
# resp.job_run.glue_version #=> String
# resp.job_run.dpu_seconds #=> Float
# resp.job_run.execution_class #=> String, one of "FLEX", "STANDARD"
+ # resp.job_run.maintenance_window #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetJobRun AWS API Documentation
#
# @overload get_job_run(params = {})
# @param [Hash] params ({})
@@ -8355,14 +8390,15 @@
# resp.job_runs[0].id #=> String
# resp.job_runs[0].attempt #=> Integer
# resp.job_runs[0].previous_run_id #=> String
# resp.job_runs[0].trigger_name #=> String
# resp.job_runs[0].job_name #=> String
+ # resp.job_runs[0].job_mode #=> String, one of "SCRIPT", "VISUAL", "NOTEBOOK"
# resp.job_runs[0].started_on #=> Time
# resp.job_runs[0].last_modified_on #=> Time
# resp.job_runs[0].completed_on #=> Time
- # resp.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.job_runs[0].arguments #=> Hash
# resp.job_runs[0].arguments["GenericString"] #=> String
# resp.job_runs[0].error_message #=> String
# resp.job_runs[0].predecessor_runs #=> Array
# resp.job_runs[0].predecessor_runs[0].job_name #=> String
@@ -8377,10 +8413,11 @@
# resp.job_runs[0].log_group_name #=> String
# resp.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.job_runs[0].glue_version #=> String
# resp.job_runs[0].dpu_seconds #=> Float
# resp.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
+ # resp.job_runs[0].maintenance_window #=> String
# resp.next_token #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetJobRuns AWS API Documentation
#
# @overload get_job_runs(params = {})
@@ -8414,10 +8451,11 @@
#
# @example Response structure
#
# resp.jobs #=> Array
# resp.jobs[0].name #=> String
+ # resp.jobs[0].job_mode #=> String, one of "SCRIPT", "VISUAL", "NOTEBOOK"
# resp.jobs[0].description #=> String
# resp.jobs[0].log_uri #=> String
# resp.jobs[0].role #=> String
# resp.jobs[0].created_on #=> Time
# resp.jobs[0].last_modified_on #=> Time
@@ -9294,10 +9332,11 @@
# resp.jobs[0].source_control_details.branch #=> String
# resp.jobs[0].source_control_details.folder #=> String
# resp.jobs[0].source_control_details.last_commit_id #=> String
# resp.jobs[0].source_control_details.auth_strategy #=> String, one of "PERSONAL_ACCESS_TOKEN", "AWS_SECRETS_MANAGER"
# resp.jobs[0].source_control_details.auth_token #=> String
+ # resp.jobs[0].maintenance_window #=> String
# resp.next_token #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetJobs AWS API Documentation
#
# @overload get_jobs(params = {})
@@ -11385,11 +11424,11 @@
# resp.trigger.actions[0].crawler_name #=> String
# resp.trigger.predicate.logical #=> String, one of "AND", "ANY"
# resp.trigger.predicate.conditions #=> Array
# resp.trigger.predicate.conditions[0].logical_operator #=> String, one of "EQUALS"
# resp.trigger.predicate.conditions[0].job_name #=> String
- # resp.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.trigger.predicate.conditions[0].crawler_name #=> String
# resp.trigger.predicate.conditions[0].crawl_state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.trigger.event_batching_condition.batch_size #=> Integer
# resp.trigger.event_batching_condition.batch_window #=> Integer
#
@@ -11450,11 +11489,11 @@
# resp.triggers[0].actions[0].crawler_name #=> String
# resp.triggers[0].predicate.logical #=> String, one of "AND", "ANY"
# resp.triggers[0].predicate.conditions #=> Array
# resp.triggers[0].predicate.conditions[0].logical_operator #=> String, one of "EQUALS"
# resp.triggers[0].predicate.conditions[0].job_name #=> String
- # resp.triggers[0].predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.triggers[0].predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.triggers[0].predicate.conditions[0].crawler_name #=> String
# resp.triggers[0].predicate.conditions[0].crawl_state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.triggers[0].event_batching_condition.batch_size #=> Integer
# resp.triggers[0].event_batching_condition.batch_window #=> Integer
# resp.next_token #=> String
@@ -12227,25 +12266,26 @@
# resp.workflow.last_run.graph.nodes[0].trigger_details.trigger.actions[0].crawler_name #=> String
# resp.workflow.last_run.graph.nodes[0].trigger_details.trigger.predicate.logical #=> String, one of "AND", "ANY"
# resp.workflow.last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions #=> Array
# resp.workflow.last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].logical_operator #=> String, one of "EQUALS"
# resp.workflow.last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].job_name #=> String
- # resp.workflow.last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.workflow.last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.workflow.last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].crawler_name #=> String
# resp.workflow.last_run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].crawl_state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.workflow.last_run.graph.nodes[0].trigger_details.trigger.event_batching_condition.batch_size #=> Integer
# resp.workflow.last_run.graph.nodes[0].trigger_details.trigger.event_batching_condition.batch_window #=> Integer
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs #=> Array
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].id #=> String
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].attempt #=> Integer
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].previous_run_id #=> String
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].trigger_name #=> String
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].job_name #=> String
+ # resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].job_mode #=> String, one of "SCRIPT", "VISUAL", "NOTEBOOK"
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].started_on #=> Time
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].last_modified_on #=> Time
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].completed_on #=> Time
- # resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].arguments #=> Hash
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].arguments["GenericString"] #=> String
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].error_message #=> String
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].predecessor_runs #=> Array
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].predecessor_runs[0].job_name #=> String
@@ -12260,10 +12300,11 @@
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].log_group_name #=> String
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].glue_version #=> String
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].dpu_seconds #=> Float
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
+ # resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].maintenance_window #=> String
# resp.workflow.last_run.graph.nodes[0].crawler_details.crawls #=> Array
# resp.workflow.last_run.graph.nodes[0].crawler_details.crawls[0].state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.workflow.last_run.graph.nodes[0].crawler_details.crawls[0].started_on #=> Time
# resp.workflow.last_run.graph.nodes[0].crawler_details.crawls[0].completed_on #=> Time
# resp.workflow.last_run.graph.nodes[0].crawler_details.crawls[0].error_message #=> String
@@ -12295,25 +12336,26 @@
# resp.workflow.graph.nodes[0].trigger_details.trigger.actions[0].crawler_name #=> String
# resp.workflow.graph.nodes[0].trigger_details.trigger.predicate.logical #=> String, one of "AND", "ANY"
# resp.workflow.graph.nodes[0].trigger_details.trigger.predicate.conditions #=> Array
# resp.workflow.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].logical_operator #=> String, one of "EQUALS"
# resp.workflow.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].job_name #=> String
- # resp.workflow.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.workflow.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.workflow.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].crawler_name #=> String
# resp.workflow.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].crawl_state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.workflow.graph.nodes[0].trigger_details.trigger.event_batching_condition.batch_size #=> Integer
# resp.workflow.graph.nodes[0].trigger_details.trigger.event_batching_condition.batch_window #=> Integer
# resp.workflow.graph.nodes[0].job_details.job_runs #=> Array
# resp.workflow.graph.nodes[0].job_details.job_runs[0].id #=> String
# resp.workflow.graph.nodes[0].job_details.job_runs[0].attempt #=> Integer
# resp.workflow.graph.nodes[0].job_details.job_runs[0].previous_run_id #=> String
# resp.workflow.graph.nodes[0].job_details.job_runs[0].trigger_name #=> String
# resp.workflow.graph.nodes[0].job_details.job_runs[0].job_name #=> String
+ # resp.workflow.graph.nodes[0].job_details.job_runs[0].job_mode #=> String, one of "SCRIPT", "VISUAL", "NOTEBOOK"
# resp.workflow.graph.nodes[0].job_details.job_runs[0].started_on #=> Time
# resp.workflow.graph.nodes[0].job_details.job_runs[0].last_modified_on #=> Time
# resp.workflow.graph.nodes[0].job_details.job_runs[0].completed_on #=> Time
- # resp.workflow.graph.nodes[0].job_details.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.workflow.graph.nodes[0].job_details.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.workflow.graph.nodes[0].job_details.job_runs[0].arguments #=> Hash
# resp.workflow.graph.nodes[0].job_details.job_runs[0].arguments["GenericString"] #=> String
# resp.workflow.graph.nodes[0].job_details.job_runs[0].error_message #=> String
# resp.workflow.graph.nodes[0].job_details.job_runs[0].predecessor_runs #=> Array
# resp.workflow.graph.nodes[0].job_details.job_runs[0].predecessor_runs[0].job_name #=> String
@@ -12328,10 +12370,11 @@
# resp.workflow.graph.nodes[0].job_details.job_runs[0].log_group_name #=> String
# resp.workflow.graph.nodes[0].job_details.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.workflow.graph.nodes[0].job_details.job_runs[0].glue_version #=> String
# resp.workflow.graph.nodes[0].job_details.job_runs[0].dpu_seconds #=> Float
# resp.workflow.graph.nodes[0].job_details.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
+ # resp.workflow.graph.nodes[0].job_details.job_runs[0].maintenance_window #=> String
# resp.workflow.graph.nodes[0].crawler_details.crawls #=> Array
# resp.workflow.graph.nodes[0].crawler_details.crawls[0].state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.workflow.graph.nodes[0].crawler_details.crawls[0].started_on #=> Time
# resp.workflow.graph.nodes[0].crawler_details.crawls[0].completed_on #=> Time
# resp.workflow.graph.nodes[0].crawler_details.crawls[0].error_message #=> String
@@ -12416,25 +12459,26 @@
# resp.run.graph.nodes[0].trigger_details.trigger.actions[0].crawler_name #=> String
# resp.run.graph.nodes[0].trigger_details.trigger.predicate.logical #=> String, one of "AND", "ANY"
# resp.run.graph.nodes[0].trigger_details.trigger.predicate.conditions #=> Array
# resp.run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].logical_operator #=> String, one of "EQUALS"
# resp.run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].job_name #=> String
- # resp.run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].crawler_name #=> String
# resp.run.graph.nodes[0].trigger_details.trigger.predicate.conditions[0].crawl_state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.run.graph.nodes[0].trigger_details.trigger.event_batching_condition.batch_size #=> Integer
# resp.run.graph.nodes[0].trigger_details.trigger.event_batching_condition.batch_window #=> Integer
# resp.run.graph.nodes[0].job_details.job_runs #=> Array
# resp.run.graph.nodes[0].job_details.job_runs[0].id #=> String
# resp.run.graph.nodes[0].job_details.job_runs[0].attempt #=> Integer
# resp.run.graph.nodes[0].job_details.job_runs[0].previous_run_id #=> String
# resp.run.graph.nodes[0].job_details.job_runs[0].trigger_name #=> String
# resp.run.graph.nodes[0].job_details.job_runs[0].job_name #=> String
+ # resp.run.graph.nodes[0].job_details.job_runs[0].job_mode #=> String, one of "SCRIPT", "VISUAL", "NOTEBOOK"
# resp.run.graph.nodes[0].job_details.job_runs[0].started_on #=> Time
# resp.run.graph.nodes[0].job_details.job_runs[0].last_modified_on #=> Time
# resp.run.graph.nodes[0].job_details.job_runs[0].completed_on #=> Time
- # resp.run.graph.nodes[0].job_details.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.run.graph.nodes[0].job_details.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.run.graph.nodes[0].job_details.job_runs[0].arguments #=> Hash
# resp.run.graph.nodes[0].job_details.job_runs[0].arguments["GenericString"] #=> String
# resp.run.graph.nodes[0].job_details.job_runs[0].error_message #=> String
# resp.run.graph.nodes[0].job_details.job_runs[0].predecessor_runs #=> Array
# resp.run.graph.nodes[0].job_details.job_runs[0].predecessor_runs[0].job_name #=> String
@@ -12449,10 +12493,11 @@
# resp.run.graph.nodes[0].job_details.job_runs[0].log_group_name #=> String
# resp.run.graph.nodes[0].job_details.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.run.graph.nodes[0].job_details.job_runs[0].glue_version #=> String
# resp.run.graph.nodes[0].job_details.job_runs[0].dpu_seconds #=> Float
# resp.run.graph.nodes[0].job_details.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
+ # resp.run.graph.nodes[0].job_details.job_runs[0].maintenance_window #=> String
# resp.run.graph.nodes[0].crawler_details.crawls #=> Array
# resp.run.graph.nodes[0].crawler_details.crawls[0].state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.run.graph.nodes[0].crawler_details.crawls[0].started_on #=> Time
# resp.run.graph.nodes[0].crawler_details.crawls[0].completed_on #=> Time
# resp.run.graph.nodes[0].crawler_details.crawls[0].error_message #=> String
@@ -12577,25 +12622,26 @@
# resp.runs[0].graph.nodes[0].trigger_details.trigger.actions[0].crawler_name #=> String
# resp.runs[0].graph.nodes[0].trigger_details.trigger.predicate.logical #=> String, one of "AND", "ANY"
# resp.runs[0].graph.nodes[0].trigger_details.trigger.predicate.conditions #=> Array
# resp.runs[0].graph.nodes[0].trigger_details.trigger.predicate.conditions[0].logical_operator #=> String, one of "EQUALS"
# resp.runs[0].graph.nodes[0].trigger_details.trigger.predicate.conditions[0].job_name #=> String
- # resp.runs[0].graph.nodes[0].trigger_details.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.runs[0].graph.nodes[0].trigger_details.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.runs[0].graph.nodes[0].trigger_details.trigger.predicate.conditions[0].crawler_name #=> String
# resp.runs[0].graph.nodes[0].trigger_details.trigger.predicate.conditions[0].crawl_state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.runs[0].graph.nodes[0].trigger_details.trigger.event_batching_condition.batch_size #=> Integer
# resp.runs[0].graph.nodes[0].trigger_details.trigger.event_batching_condition.batch_window #=> Integer
# resp.runs[0].graph.nodes[0].job_details.job_runs #=> Array
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].id #=> String
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].attempt #=> Integer
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].previous_run_id #=> String
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].trigger_name #=> String
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].job_name #=> String
+ # resp.runs[0].graph.nodes[0].job_details.job_runs[0].job_mode #=> String, one of "SCRIPT", "VISUAL", "NOTEBOOK"
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].started_on #=> Time
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].last_modified_on #=> Time
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].completed_on #=> Time
- # resp.runs[0].graph.nodes[0].job_details.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.runs[0].graph.nodes[0].job_details.job_runs[0].job_run_state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].arguments #=> Hash
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].arguments["GenericString"] #=> String
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].error_message #=> String
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].predecessor_runs #=> Array
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].predecessor_runs[0].job_name #=> String
@@ -12610,10 +12656,11 @@
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].log_group_name #=> String
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].glue_version #=> String
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].dpu_seconds #=> Float
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
+ # resp.runs[0].graph.nodes[0].job_details.job_runs[0].maintenance_window #=> String
# resp.runs[0].graph.nodes[0].crawler_details.crawls #=> Array
# resp.runs[0].graph.nodes[0].crawler_details.crawls[0].state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.runs[0].graph.nodes[0].crawler_details.crawls[0].started_on #=> Time
# resp.runs[0].graph.nodes[0].crawler_details.crawls[0].completed_on #=> Time
# resp.runs[0].graph.nodes[0].crawler_details.crawls[0].error_message #=> String
@@ -16985,11 +17032,11 @@
# logical: "AND", # accepts AND, ANY
# conditions: [
# {
# logical_operator: "EQUALS", # accepts EQUALS
# job_name: "NameString",
- # state: "STARTING", # accepts STARTING, RUNNING, STOPPING, STOPPED, SUCCEEDED, FAILED, TIMEOUT, ERROR, WAITING
+ # state: "STARTING", # accepts STARTING, RUNNING, STOPPING, STOPPED, SUCCEEDED, FAILED, TIMEOUT, ERROR, WAITING, EXPIRED
# crawler_name: "NameString",
# crawl_state: "RUNNING", # accepts RUNNING, CANCELLING, CANCELLED, SUCCEEDED, FAILED, ERROR
# },
# ],
# },
@@ -17019,11 +17066,11 @@
# resp.trigger.actions[0].crawler_name #=> String
# resp.trigger.predicate.logical #=> String, one of "AND", "ANY"
# resp.trigger.predicate.conditions #=> Array
# resp.trigger.predicate.conditions[0].logical_operator #=> String, one of "EQUALS"
# resp.trigger.predicate.conditions[0].job_name #=> String
- # resp.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING"
+ # resp.trigger.predicate.conditions[0].state #=> String, one of "STARTING", "RUNNING", "STOPPING", "STOPPED", "SUCCEEDED", "FAILED", "TIMEOUT", "ERROR", "WAITING", "EXPIRED"
# resp.trigger.predicate.conditions[0].crawler_name #=> String
# resp.trigger.predicate.conditions[0].crawl_state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.trigger.event_batching_condition.batch_size #=> Integer
# resp.trigger.event_batching_condition.batch_window #=> Integer
#
@@ -17143,10 +17190,10 @@
operation: config.api.operation(operation_name),
client: self,
params: params,
config: config)
context[:gem_name] = 'aws-sdk-glue'
- context[:gem_version] = '1.172.0'
+ context[:gem_version] = '1.175.0'
Seahorse::Client::Request.new(handlers, context)
end
# @api private
# @deprecated