# Path: google/cloud/dataflow_v1beta3/types/environment.py
# class JobType(proto.Enum):
# class FlexResourceSchedulingGoal(proto.Enum):
# class TeardownPolicy(proto.Enum):
# class DefaultPackageSet(proto.Enum):
# class AutoscalingAlgorithm(proto.Enum):
# class WorkerIPAddressConfiguration(proto.Enum):
# class ShuffleMode(proto.Enum):
# class Environment(proto.Message):
# class Package(proto.Message):
# class Disk(proto.Message):
# class WorkerSettings(proto.Message):
# class TaskRunnerSettings(proto.Message):
# class AutoscalingSettings(proto.Message):
# class SdkHarnessContainerImage(proto.Message):
# class WorkerPool(proto.Message):
# class DebugOptions(proto.Message):
#     JOB_TYPE_UNKNOWN = 0
#     JOB_TYPE_BATCH = 1
#     JOB_TYPE_STREAMING = 2
#     FLEXRS_UNSPECIFIED = 0
#     FLEXRS_SPEED_OPTIMIZED = 1
#     FLEXRS_COST_OPTIMIZED = 2
#     TEARDOWN_POLICY_UNKNOWN = 0
#     TEARDOWN_ALWAYS = 1
#     TEARDOWN_ON_SUCCESS = 2
#     TEARDOWN_NEVER = 3
#     DEFAULT_PACKAGE_SET_UNKNOWN = 0
#     DEFAULT_PACKAGE_SET_NONE = 1
#     DEFAULT_PACKAGE_SET_JAVA = 2
#     DEFAULT_PACKAGE_SET_PYTHON = 3
#     AUTOSCALING_ALGORITHM_UNKNOWN = 0
#     AUTOSCALING_ALGORITHM_NONE = 1
#     AUTOSCALING_ALGORITHM_BASIC = 2
#     WORKER_IP_UNSPECIFIED = 0
#     WORKER_IP_PUBLIC = 1
#     WORKER_IP_PRIVATE = 2
#     SHUFFLE_MODE_UNSPECIFIED = 0
#     VM_BASED = 1
#     SERVICE_BASED = 2
# 
# Path: google/cloud/dataflow_v1beta3/types/jobs.py
# class KindType(proto.Enum):
# class JobState(proto.Enum):
# class JobView(proto.Enum):
# class Job(proto.Message):
# class DatastoreIODetails(proto.Message):
# class PubSubIODetails(proto.Message):
# class FileIODetails(proto.Message):
# class BigTableIODetails(proto.Message):
# class BigQueryIODetails(proto.Message):
# class SpannerIODetails(proto.Message):
# class SdkVersion(proto.Message):
#     class SdkSupportStatus(proto.Enum):
# class JobMetadata(proto.Message):
# class ExecutionStageState(proto.Message):
# class PipelineDescription(proto.Message):
# class TransformSummary(proto.Message):
# class ExecutionStageSummary(proto.Message):
#     class StageSource(proto.Message):
#     class ComponentTransform(proto.Message):
#     class ComponentSource(proto.Message):
# class DisplayData(proto.Message):
# class Step(proto.Message):
# class JobExecutionInfo(proto.Message):
# class JobExecutionStageInfo(proto.Message):
# class CreateJobRequest(proto.Message):
# class GetJobRequest(proto.Message):
# class UpdateJobRequest(proto.Message):
# class ListJobsRequest(proto.Message):
#     class Filter(proto.Enum):
# class FailedLocation(proto.Message):
# class ListJobsResponse(proto.Message):
# class SnapshotJobRequest(proto.Message):
# class CheckActiveJobsRequest(proto.Message):
# class CheckActiveJobsResponse(proto.Message):
#     UNKNOWN_KIND = 0
#     PAR_DO_KIND = 1
#     GROUP_BY_KEY_KIND = 2
#     FLATTEN_KIND = 3
#     READ_KIND = 4
#     WRITE_KIND = 5
#     CONSTANT_KIND = 6
#     SINGLETON_KIND = 7
#     SHUFFLE_KIND = 8
#     JOB_STATE_UNKNOWN = 0
#     JOB_STATE_STOPPED = 1
#     JOB_STATE_RUNNING = 2
#     JOB_STATE_DONE = 3
#     JOB_STATE_FAILED = 4
#     JOB_STATE_CANCELLED = 5
#     JOB_STATE_UPDATED = 6
#     JOB_STATE_DRAINING = 7
#     JOB_STATE_DRAINED = 8
#     JOB_STATE_PENDING = 9
#     JOB_STATE_CANCELLING = 10
#     JOB_STATE_QUEUED = 11
#     JOB_STATE_RESOURCE_CLEANING_UP = 12
#     JOB_VIEW_UNKNOWN = 0
#     JOB_VIEW_SUMMARY = 1
#     JOB_VIEW_ALL = 2
#     JOB_VIEW_DESCRIPTION = 3
#         UNKNOWN = 0
#         SUPPORTED = 1
#         STALE = 2
#         DEPRECATED = 3
#         UNSUPPORTED = 4
#         UNKNOWN = 0
#         ALL = 1
#         TERMINATED = 2
#         ACTIVE = 3
#     def raw_page(self):


import proto  # type: ignore
from google.cloud.dataflow_v1beta3.types import environment as gd_environment
from google.cloud.dataflow_v1beta3.types import jobs
from google.rpc import status_pb2  # type: ignore
            The [regional endpoint]
            (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints)
            to which to direct the request.
    """

    project_id = proto.Field(proto.STRING, number=1,)
    validate_only = proto.Field(proto.BOOL, number=2,)
    gcs_path = proto.Field(proto.STRING, number=3, oneof="template",)
    dynamic_template = proto.Field(
        proto.MESSAGE,
        number=6,
        oneof="template",
        message="DynamicTemplateLaunchParams",
    )
    launch_parameters = proto.Field(
        proto.MESSAGE, number=4, message="LaunchTemplateParameters",
    )
    location = proto.Field(proto.STRING, number=5,)


class LaunchTemplateResponse(proto.Message):
    r"""Response to the request to launch a template.

    Attributes:
        job (google.cloud.dataflow_v1beta3.types.Job):
            The job that was launched, if the request was
            not a dry run and the job was successfully
            launched.
    """


# Path: google/cloud/dataflow_v1beta3/types/environment.py
# class JobType(proto.Enum):
# class FlexResourceSchedulingGoal(proto.Enum):
# class TeardownPolicy(proto.Enum):
# class DefaultPackageSet(proto.Enum):
# class AutoscalingAlgorithm(proto.Enum):
# class WorkerIPAddressConfiguration(proto.Enum):
# class ShuffleMode(proto.Enum):
# class Environment(proto.Message):
# class Package(proto.Message):
# class Disk(proto.Message):
# class WorkerSettings(proto.Message):
# class TaskRunnerSettings(proto.Message):
# class AutoscalingSettings(proto.Message):
# class SdkHarnessContainerImage(proto.Message):
# class WorkerPool(proto.Message):
# class DebugOptions(proto.Message):
#     JOB_TYPE_UNKNOWN = 0
#     JOB_TYPE_BATCH = 1
#     JOB_TYPE_STREAMING = 2
#     FLEXRS_UNSPECIFIED = 0
#     FLEXRS_SPEED_OPTIMIZED = 1
#     FLEXRS_COST_OPTIMIZED = 2
#     TEARDOWN_POLICY_UNKNOWN = 0
#     TEARDOWN_ALWAYS = 1
#     TEARDOWN_ON_SUCCESS = 2
#     TEARDOWN_NEVER = 3
#     DEFAULT_PACKAGE_SET_UNKNOWN = 0
#     DEFAULT_PACKAGE_SET_NONE = 1
#     DEFAULT_PACKAGE_SET_JAVA = 2
#     DEFAULT_PACKAGE_SET_PYTHON = 3
#     AUTOSCALING_ALGORITHM_UNKNOWN = 0
#     AUTOSCALING_ALGORITHM_NONE = 1
#     AUTOSCALING_ALGORITHM_BASIC = 2
#     WORKER_IP_UNSPECIFIED = 0
#     WORKER_IP_PUBLIC = 1
#     WORKER_IP_PRIVATE = 2
#     SHUFFLE_MODE_UNSPECIFIED = 0
#     VM_BASED = 1
#     SERVICE_BASED = 2
# 
# Path: google/cloud/dataflow_v1beta3/types/jobs.py
# class KindType(proto.Enum):
# class JobState(proto.Enum):
# class JobView(proto.Enum):
# class Job(proto.Message):
# class DatastoreIODetails(proto.Message):
# class PubSubIODetails(proto.Message):
# class FileIODetails(proto.Message):
# class BigTableIODetails(proto.Message):
# class BigQueryIODetails(proto.Message):
# class SpannerIODetails(proto.Message):
# class SdkVersion(proto.Message):
#     class SdkSupportStatus(proto.Enum):
# class JobMetadata(proto.Message):
# class ExecutionStageState(proto.Message):
# class PipelineDescription(proto.Message):
# class TransformSummary(proto.Message):
# class ExecutionStageSummary(proto.Message):
#     class StageSource(proto.Message):
#     class ComponentTransform(proto.Message):
#     class ComponentSource(proto.Message):
# class DisplayData(proto.Message):
# class Step(proto.Message):
# class JobExecutionInfo(proto.Message):
# class JobExecutionStageInfo(proto.Message):
# class CreateJobRequest(proto.Message):
# class GetJobRequest(proto.Message):
# class UpdateJobRequest(proto.Message):
# class ListJobsRequest(proto.Message):
#     class Filter(proto.Enum):
# class FailedLocation(proto.Message):
# class ListJobsResponse(proto.Message):
# class SnapshotJobRequest(proto.Message):
# class CheckActiveJobsRequest(proto.Message):
# class CheckActiveJobsResponse(proto.Message):
#     UNKNOWN_KIND = 0
#     PAR_DO_KIND = 1
#     GROUP_BY_KEY_KIND = 2
#     FLATTEN_KIND = 3
#     READ_KIND = 4
#     WRITE_KIND = 5
#     CONSTANT_KIND = 6
#     SINGLETON_KIND = 7
#     SHUFFLE_KIND = 8
#     JOB_STATE_UNKNOWN = 0
#     JOB_STATE_STOPPED = 1
#     JOB_STATE_RUNNING = 2
#     JOB_STATE_DONE = 3
#     JOB_STATE_FAILED = 4
#     JOB_STATE_CANCELLED = 5
#     JOB_STATE_UPDATED = 6
#     JOB_STATE_DRAINING = 7
#     JOB_STATE_DRAINED = 8
#     JOB_STATE_PENDING = 9
#     JOB_STATE_CANCELLING = 10
#     JOB_STATE_QUEUED = 11
#     JOB_STATE_RESOURCE_CLEANING_UP = 12
#     JOB_VIEW_UNKNOWN = 0
#     JOB_VIEW_SUMMARY = 1
#     JOB_VIEW_ALL = 2
#     JOB_VIEW_DESCRIPTION = 3
#         UNKNOWN = 0
#         SUPPORTED = 1
#         STALE = 2
#         DEPRECATED = 3
#         UNSUPPORTED = 4
#         UNKNOWN = 0
#         ALL = 1
#         TERMINATED = 2
#         ACTIVE = 3
#     def raw_page(self):


# Path: google/cloud/dataflow_v1beta3/types/templates.py
import proto  # type: ignore
from google.cloud.dataflow_v1beta3.types import environment as gd_environment
from google.cloud.dataflow_v1beta3.types import jobs
from google.rpc import status_pb2  # type: ignore

            The [regional endpoint]
            (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints)
            to which to direct the request.
    """

    project_id = proto.Field(proto.STRING, number=1,)
    validate_only = proto.Field(proto.BOOL, number=2,)
    gcs_path = proto.Field(proto.STRING, number=3, oneof="template",)
    dynamic_template = proto.Field(
        proto.MESSAGE,
        number=6,
        oneof="template",
        message="DynamicTemplateLaunchParams",
    )
    launch_parameters = proto.Field(
        proto.MESSAGE, number=4, message="LaunchTemplateParameters",
    )
    location = proto.Field(proto.STRING, number=5,)


class LaunchTemplateResponse(proto.Message):
    r"""Response to the request to launch a template.

    Attributes:
        job (google.cloud.dataflow_v1beta3.types.Job):
            The job that was launched, if the request was
            not a dry run and the job was successfully
            launched.
    """


    job = proto.Field(proto.MESSAGE, number=1, message=jobs.Job,)