Class: Google::Apis::DataprocV1::WorkflowTemplate
- Inherits:
-
Object
- Object
- Google::Apis::DataprocV1::WorkflowTemplate
- Includes:
- Core::Hashable, Core::JsonObjectSupport
- Defined in:
- generated/google/apis/dataproc_v1/classes.rb,
generated/google/apis/dataproc_v1/representations.rb,
generated/google/apis/dataproc_v1/representations.rb
Overview
A Dataproc workflow template resource.
Instance Attribute Summary collapse
-
#create_time ⇒ String
Output only.
-
#dag_timeout ⇒ String
Optional.
-
#id ⇒ String
Corresponds to the JSON property
id
. -
#jobs ⇒ Array<Google::Apis::DataprocV1::OrderedJob>
Required.
-
#labels ⇒ Hash<String,String>
Optional.
-
#name ⇒ String
Output only.
-
#parameters ⇒ Array<Google::Apis::DataprocV1::TemplateParameter>
Optional.
-
#placement ⇒ Google::Apis::DataprocV1::WorkflowTemplatePlacement
Specifies workflow execution target.Either managed_cluster or cluster_selector is required.
-
#update_time ⇒ String
Output only.
-
#version ⇒ Fixnum
Optional.
Instance Method Summary collapse
-
#initialize(**args) ⇒ WorkflowTemplate
constructor
A new instance of WorkflowTemplate.
-
#update!(**args) ⇒ Object
Update properties of this object.
Constructor Details
#initialize(**args) ⇒ WorkflowTemplate
Returns a new instance of WorkflowTemplate.
3535 3536 3537 |
# File 'generated/google/apis/dataproc_v1/classes.rb', line 3535 def initialize(**args) update!(**args) end |
Instance Attribute Details
#create_time ⇒ String
Output only. The time template was created.
Corresponds to the JSON property createTime
3462 3463 3464 |
# File 'generated/google/apis/dataproc_v1/classes.rb', line 3462 def create_time @create_time end |
#dag_timeout ⇒ String
Optional. Timeout duration for the DAG of jobs. You can use "s", "m", "h", and
"d" suffixes for second, minute, hour, and day duration values, respectively.
The timeout duration must be from 10 minutes ("10m") to 24 hours ("24h" or "1d"
). The timer begins when the first job is submitted. If the workflow is
running at the end of the timeout period, any remaining jobs are cancelled,
the workflow is ended, and if the workflow was running on a managed cluster,
the cluster is deleted.
Corresponds to the JSON property dagTimeout
3473 3474 3475 |
# File 'generated/google/apis/dataproc_v1/classes.rb', line 3473 def dag_timeout @dag_timeout end |
#id ⇒ String
Corresponds to the JSON property id
3478 3479 3480 |
# File 'generated/google/apis/dataproc_v1/classes.rb', line 3478 def id @id end |
#jobs ⇒ Array<Google::Apis::DataprocV1::OrderedJob>
Required. The Directed Acyclic Graph of Jobs to submit.
Corresponds to the JSON property jobs
3483 3484 3485 |
# File 'generated/google/apis/dataproc_v1/classes.rb', line 3483 def jobs @jobs end |
#labels ⇒ Hash<String,String>
Optional. The labels to associate with this template. These labels will be
propagated to all jobs and clusters created by the workflow instance.Label
keys must contain 1 to 63 characters, and must conform to RFC 1035 (https://
www.ietf.org/rfc/rfc1035.txt).Label values may be empty, but, if present, must
contain 1 to 63 characters, and must conform to RFC 1035 (https://www.ietf.org/
rfc/rfc1035.txt).No more than 32 labels can be associated with a template.
Corresponds to the JSON property labels
3493 3494 3495 |
# File 'generated/google/apis/dataproc_v1/classes.rb', line 3493 def labels @labels end |
#name ⇒ String
Output only. The resource name of the workflow template, as described in https:
//cloud.google.com/apis/design/resource_names. For projects.regions.
workflowTemplates, the resource name of the template has the following format:
projects/project_id
/regions/region
/workflowTemplates/template_id
For
projects.locations.workflowTemplates, the resource name of the template has
the following format: projects/project_id
/locations/location
/
workflowTemplates/template_id
Corresponds to the JSON property name
3504 3505 3506 |
# File 'generated/google/apis/dataproc_v1/classes.rb', line 3504 def name @name end |
#parameters ⇒ Array<Google::Apis::DataprocV1::TemplateParameter>
Optional. Template parameters whose values are substituted into the template.
Values for parameters must be provided when the template is instantiated.
Corresponds to the JSON property parameters
3510 3511 3512 |
# File 'generated/google/apis/dataproc_v1/classes.rb', line 3510 def parameters @parameters end |
#placement ⇒ Google::Apis::DataprocV1::WorkflowTemplatePlacement
Specifies workflow execution target.Either managed_cluster or cluster_selector
is required.
Corresponds to the JSON property placement
3516 3517 3518 |
# File 'generated/google/apis/dataproc_v1/classes.rb', line 3516 def placement @placement end |
#update_time ⇒ String
Output only. The time template was last updated.
Corresponds to the JSON property updateTime
3521 3522 3523 |
# File 'generated/google/apis/dataproc_v1/classes.rb', line 3521 def update_time @update_time end |
#version ⇒ Fixnum
Optional. Used to perform a consistent read-modify-write.This field should be
left blank for a CreateWorkflowTemplate request. It is required for an
UpdateWorkflowTemplate request, and must match the current server version. A
typical update template flow would fetch the current template with a
GetWorkflowTemplate request, which will return the current template with the
version field filled in with the current server version. The user updates
other fields in the template, then returns it as part of the
UpdateWorkflowTemplate request.
Corresponds to the JSON property version
3533 3534 3535 |
# File 'generated/google/apis/dataproc_v1/classes.rb', line 3533 def version @version end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
3540 3541 3542 3543 3544 3545 3546 3547 3548 3549 3550 3551 |
# File 'generated/google/apis/dataproc_v1/classes.rb', line 3540 def update!(**args) @create_time = args[:create_time] if args.key?(:create_time) @dag_timeout = args[:dag_timeout] if args.key?(:dag_timeout) @id = args[:id] if args.key?(:id) @jobs = args[:jobs] if args.key?(:jobs) @labels = args[:labels] if args.key?(:labels) @name = args[:name] if args.key?(:name) @parameters = args[:parameters] if args.key?(:parameters) @placement = args[:placement] if args.key?(:placement) @update_time = args[:update_time] if args.key?(:update_time) @version = args[:version] if args.key?(:version) end |