LaunchFlexTemplateParameter(mapping=None, *, ignore_unknown_fields=False, **kwargs)
Launch FlexTemplate Parameter. .. attribute:: job_name
Required. The job name to use for the created job. For update job request, job name should be same as the existing running job.
:type: str
Attributes | |
---|---|
Name | Description |
container_spec |
google.cloud.dataflow_v1beta3.types.ContainerSpec
Spec about the container image to launch. |
container_spec_gcs_path |
str
Cloud Storage path to a file with json serialized ContainerSpec as content. |
parameters |
Sequence[google.cloud.dataflow_v1beta3.types.LaunchFlexTemplateParameter.ParametersEntry]
The parameters for FlexTemplate. Ex. {"num_workers":"5"} |
launch_options |
Sequence[google.cloud.dataflow_v1beta3.types.LaunchFlexTemplateParameter.LaunchOptionsEntry]
Launch options for this flex template job. This is a common set of options across languages and templates. This should not be used to pass job parameters. |
environment |
google.cloud.dataflow_v1beta3.types.FlexTemplateRuntimeEnvironment
The runtime environment for the FlexTemplate job |
update |
bool
Set this to true if you are sending a request to update a running streaming job. When set, the job name should be the same as the running job. |
transform_name_mappings |
Sequence[google.cloud.dataflow_v1beta3.types.LaunchFlexTemplateParameter.TransformNameMappingsEntry]
Use this to pass transform_name_mappings for streaming update jobs. Ex:{"oldTransformName":"newTransformName",...}' |
Classes
LaunchOptionsEntry
LaunchOptionsEntry(mapping=None, *, ignore_unknown_fields=False, **kwargs)
The abstract base class for a message.
Parameters | |
---|---|
Name | Description |
kwargs |
dict
Keys and values corresponding to the fields of the message. |
mapping |
Union[dict,
A dictionary or message to be used to determine the values for this message. |
ignore_unknown_fields |
Optional(bool)
If True, do not raise errors for unknown fields. Only applied if |
ParametersEntry
ParametersEntry(mapping=None, *, ignore_unknown_fields=False, **kwargs)
The abstract base class for a message.
Parameters | |
---|---|
Name | Description |
kwargs |
dict
Keys and values corresponding to the fields of the message. |
mapping |
Union[dict,
A dictionary or message to be used to determine the values for this message. |
ignore_unknown_fields |
Optional(bool)
If True, do not raise errors for unknown fields. Only applied if |
TransformNameMappingsEntry
TransformNameMappingsEntry(mapping=None, *, ignore_unknown_fields=False, **kwargs)
The abstract base class for a message.
Parameters | |
---|---|
Name | Description |
kwargs |
dict
Keys and values corresponding to the fields of the message. |
mapping |
Union[dict,
A dictionary or message to be used to determine the values for this message. |
ignore_unknown_fields |
Optional(bool)
If True, do not raise errors for unknown fields. Only applied if |