# 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/snapshots.py
# class SnapshotState(proto.Enum):
# class PubsubSnapshotMetadata(proto.Message):
# class Snapshot(proto.Message):
# class GetSnapshotRequest(proto.Message):
# class DeleteSnapshotRequest(proto.Message):
# class DeleteSnapshotResponse(proto.Message):
# class ListSnapshotsRequest(proto.Message):
# class ListSnapshotsResponse(proto.Message):
#     UNKNOWN_SNAPSHOT_STATE = 0
#     PENDING = 1
#     RUNNING = 2
#     READY = 3
#     FAILED = 4
#     DELETED = 5


import abc
import pkg_resources
import google.auth  # type: ignore
import google.api_core
from typing import Awaitable, Callable, Dict, Optional, Sequence, Union
from google.api_core import exceptions as core_exceptions
from google.api_core import gapic_v1
from google.api_core import retry as retries
from google.auth import credentials as ga_credentials  # type: ignore
from google.oauth2 import service_account  # type: ignore
from google.cloud.dataflow_v1beta3.types import jobs
from google.cloud.dataflow_v1beta3.types import snapshots
        self,
    ) -> Callable[
        [jobs.ListJobsRequest],
        Union[jobs.ListJobsResponse, Awaitable[jobs.ListJobsResponse]],
    ]:
        raise NotImplementedError()

    @property
    def aggregated_list_jobs(
        self,
    ) -> Callable[
        [jobs.ListJobsRequest],
        Union[jobs.ListJobsResponse, Awaitable[jobs.ListJobsResponse]],
    ]:
        raise NotImplementedError()

    @property
    def check_active_jobs(
        self,
    ) -> Callable[
        [jobs.CheckActiveJobsRequest],
        Union[jobs.CheckActiveJobsResponse, Awaitable[jobs.CheckActiveJobsResponse]],
    ]:
        raise NotImplementedError()

    @property
    def snapshot_job(
        self,
    ) -> Callable[
        [jobs.SnapshotJobRequest],

# 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/snapshots.py
# class SnapshotState(proto.Enum):
# class PubsubSnapshotMetadata(proto.Message):
# class Snapshot(proto.Message):
# class GetSnapshotRequest(proto.Message):
# class DeleteSnapshotRequest(proto.Message):
# class DeleteSnapshotResponse(proto.Message):
# class ListSnapshotsRequest(proto.Message):
# class ListSnapshotsResponse(proto.Message):
#     UNKNOWN_SNAPSHOT_STATE = 0
#     PENDING = 1
#     RUNNING = 2
#     READY = 3
#     FAILED = 4
#     DELETED = 5


# Path: google/cloud/dataflow_v1beta3/services/jobs_v1_beta3/transports/base.py
import abc
import pkg_resources
import google.auth  # type: ignore
import google.api_core
from typing import Awaitable, Callable, Dict, Optional, Sequence, Union
from google.api_core import exceptions as core_exceptions
from google.api_core import gapic_v1
from google.api_core import retry as retries
from google.auth import credentials as ga_credentials  # type: ignore
from google.oauth2 import service_account  # type: ignore
from google.cloud.dataflow_v1beta3.types import jobs
from google.cloud.dataflow_v1beta3.types import snapshots

        self,
    ) -> Callable[
        [jobs.ListJobsRequest],
        Union[jobs.ListJobsResponse, Awaitable[jobs.ListJobsResponse]],
    ]:
        raise NotImplementedError()

    @property
    def aggregated_list_jobs(
        self,
    ) -> Callable[
        [jobs.ListJobsRequest],
        Union[jobs.ListJobsResponse, Awaitable[jobs.ListJobsResponse]],
    ]:
        raise NotImplementedError()

    @property
    def check_active_jobs(
        self,
    ) -> Callable[
        [jobs.CheckActiveJobsRequest],
        Union[jobs.CheckActiveJobsResponse, Awaitable[jobs.CheckActiveJobsResponse]],
    ]:
        raise NotImplementedError()

    @property
    def snapshot_job(
        self,
    ) -> Callable[
        [jobs.SnapshotJobRequest],

        Union[snapshots.Snapshot, Awaitable[snapshots.Snapshot]],