chore: prepare v1beta3 (#2)

PiperOrigin-RevId: 381356178

Source-Link: googleapis/googleapis@6fa6c00

Source-Link: googleapis/googleapis-gen@ba89d92

packages/google-cloud-dataflow-client/.coveragerc

@@ -4,7 +4,7 @@ branch = True
 [report]
 show_missing = True
 omit =
-    google/dataflow/__init__.py
+    google/cloud/dataflow/__init__.py
 exclude_lines =
     # Re-enable the standard pragma
     pragma: NO COVER

packages/google-cloud-dataflow-client/docs/dataflow_v1beta3/flex_templates_service.rst

@@ -1,6 +1,6 @@
 FlexTemplatesService
 --------------------------------------
 
-.. automodule:: google.dataflow_v1beta3.services.flex_templates_service
+.. automodule:: google.cloud.dataflow_v1beta3.services.flex_templates_service
     :members:
     :inherited-members:

packages/google-cloud-dataflow-client/docs/dataflow_v1beta3/jobs_v1_beta3.rst

@@ -1,10 +1,10 @@
 JobsV1Beta3
 -----------------------------
 
-.. automodule:: google.dataflow_v1beta3.services.jobs_v1_beta3
+.. automodule:: google.cloud.dataflow_v1beta3.services.jobs_v1_beta3
     :members:
     :inherited-members:
 
-.. automodule:: google.dataflow_v1beta3.services.jobs_v1_beta3.pagers
+.. automodule:: google.cloud.dataflow_v1beta3.services.jobs_v1_beta3.pagers
     :members:
     :inherited-members:

packages/google-cloud-dataflow-client/docs/dataflow_v1beta3/messages_v1_beta3.rst

@@ -1,10 +1,10 @@
 MessagesV1Beta3
 ---------------------------------
 
-.. automodule:: google.dataflow_v1beta3.services.messages_v1_beta3
+.. automodule:: google.cloud.dataflow_v1beta3.services.messages_v1_beta3
     :members:
     :inherited-members:
 
-.. automodule:: google.dataflow_v1beta3.services.messages_v1_beta3.pagers
+.. automodule:: google.cloud.dataflow_v1beta3.services.messages_v1_beta3.pagers
     :members:
     :inherited-members:

packages/google-cloud-dataflow-client/docs/dataflow_v1beta3/metrics_v1_beta3.rst

@@ -1,10 +1,10 @@
 MetricsV1Beta3
 --------------------------------
 
-.. automodule:: google.dataflow_v1beta3.services.metrics_v1_beta3
+.. automodule:: google.cloud.dataflow_v1beta3.services.metrics_v1_beta3
     :members:
     :inherited-members:
 
-.. automodule:: google.dataflow_v1beta3.services.metrics_v1_beta3.pagers
+.. automodule:: google.cloud.dataflow_v1beta3.services.metrics_v1_beta3.pagers
     :members:
     :inherited-members:

packages/google-cloud-dataflow-client/docs/dataflow_v1beta3/services.rst

@@ -1,5 +1,5 @@
-Services for Google Dataflow v1beta3 API
-========================================
+Services for Google Cloud Dataflow v1beta3 API
+==============================================
 .. toctree::
     :maxdepth: 2
 

packages/google-cloud-dataflow-client/docs/dataflow_v1beta3/snapshots_v1_beta3.rst

@@ -1,6 +1,6 @@
 SnapshotsV1Beta3
 ----------------------------------
 
-.. automodule:: google.dataflow_v1beta3.services.snapshots_v1_beta3
+.. automodule:: google.cloud.dataflow_v1beta3.services.snapshots_v1_beta3
     :members:
     :inherited-members:

packages/google-cloud-dataflow-client/docs/dataflow_v1beta3/templates_service.rst

@@ -1,6 +1,6 @@
 TemplatesService
 ----------------------------------
 
-.. automodule:: google.dataflow_v1beta3.services.templates_service
+.. automodule:: google.cloud.dataflow_v1beta3.services.templates_service
     :members:
     :inherited-members:

packages/google-cloud-dataflow-client/docs/dataflow_v1beta3/types.rst

@@ -1,7 +1,7 @@
-Types for Google Dataflow v1beta3 API
-=====================================
+Types for Google Cloud Dataflow v1beta3 API
+===========================================
 
-.. automodule:: google.dataflow_v1beta3.types
+.. automodule:: google.cloud.dataflow_v1beta3.types
     :members:
     :undoc-members:
     :show-inheritance:

packages/google-cloud-dataflow-client/google/cloud/dataflow/__init__.py

@@ -0,0 +1,280 @@
+# -*- coding: utf-8 -*-
+# Copyright 2020 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+from google.cloud.dataflow_v1beta3.services.flex_templates_service.client import (
+    FlexTemplatesServiceClient,
+)
+from google.cloud.dataflow_v1beta3.services.flex_templates_service.async_client import (
+    FlexTemplatesServiceAsyncClient,
+)
+from google.cloud.dataflow_v1beta3.services.jobs_v1_beta3.client import (
+    JobsV1Beta3Client,
+)
+from google.cloud.dataflow_v1beta3.services.jobs_v1_beta3.async_client import (
+    JobsV1Beta3AsyncClient,
+)
+from google.cloud.dataflow_v1beta3.services.messages_v1_beta3.client import (
+    MessagesV1Beta3Client,
+)
+from google.cloud.dataflow_v1beta3.services.messages_v1_beta3.async_client import (
+    MessagesV1Beta3AsyncClient,
+)
+from google.cloud.dataflow_v1beta3.services.metrics_v1_beta3.client import (
+    MetricsV1Beta3Client,
+)
+from google.cloud.dataflow_v1beta3.services.metrics_v1_beta3.async_client import (
+    MetricsV1Beta3AsyncClient,
+)
+from google.cloud.dataflow_v1beta3.services.snapshots_v1_beta3.client import (
+    SnapshotsV1Beta3Client,
+)
+from google.cloud.dataflow_v1beta3.services.snapshots_v1_beta3.async_client import (
+    SnapshotsV1Beta3AsyncClient,
+)
+from google.cloud.dataflow_v1beta3.services.templates_service.client import (
+    TemplatesServiceClient,
+)
+from google.cloud.dataflow_v1beta3.services.templates_service.async_client import (
+    TemplatesServiceAsyncClient,
+)
+
+from google.cloud.dataflow_v1beta3.types.environment import AutoscalingSettings
+from google.cloud.dataflow_v1beta3.types.environment import DebugOptions
+from google.cloud.dataflow_v1beta3.types.environment import Disk
+from google.cloud.dataflow_v1beta3.types.environment import Environment
+from google.cloud.dataflow_v1beta3.types.environment import Package
+from google.cloud.dataflow_v1beta3.types.environment import SdkHarnessContainerImage
+from google.cloud.dataflow_v1beta3.types.environment import TaskRunnerSettings
+from google.cloud.dataflow_v1beta3.types.environment import WorkerPool
+from google.cloud.dataflow_v1beta3.types.environment import WorkerSettings
+from google.cloud.dataflow_v1beta3.types.environment import AutoscalingAlgorithm
+from google.cloud.dataflow_v1beta3.types.environment import DefaultPackageSet
+from google.cloud.dataflow_v1beta3.types.environment import FlexResourceSchedulingGoal
+from google.cloud.dataflow_v1beta3.types.environment import JobType
+from google.cloud.dataflow_v1beta3.types.environment import ShuffleMode
+from google.cloud.dataflow_v1beta3.types.environment import TeardownPolicy
+from google.cloud.dataflow_v1beta3.types.environment import WorkerIPAddressConfiguration
+from google.cloud.dataflow_v1beta3.types.jobs import BigQueryIODetails
+from google.cloud.dataflow_v1beta3.types.jobs import BigTableIODetails
+from google.cloud.dataflow_v1beta3.types.jobs import CheckActiveJobsRequest
+from google.cloud.dataflow_v1beta3.types.jobs import CheckActiveJobsResponse
+from google.cloud.dataflow_v1beta3.types.jobs import CreateJobRequest
+from google.cloud.dataflow_v1beta3.types.jobs import DatastoreIODetails
+from google.cloud.dataflow_v1beta3.types.jobs import DisplayData
+from google.cloud.dataflow_v1beta3.types.jobs import ExecutionStageState
+from google.cloud.dataflow_v1beta3.types.jobs import ExecutionStageSummary
+from google.cloud.dataflow_v1beta3.types.jobs import FailedLocation
+from google.cloud.dataflow_v1beta3.types.jobs import FileIODetails
+from google.cloud.dataflow_v1beta3.types.jobs import GetJobRequest
+from google.cloud.dataflow_v1beta3.types.jobs import Job
+from google.cloud.dataflow_v1beta3.types.jobs import JobExecutionInfo
+from google.cloud.dataflow_v1beta3.types.jobs import JobExecutionStageInfo
+from google.cloud.dataflow_v1beta3.types.jobs import JobMetadata
+from google.cloud.dataflow_v1beta3.types.jobs import ListJobsRequest
+from google.cloud.dataflow_v1beta3.types.jobs import ListJobsResponse
+from google.cloud.dataflow_v1beta3.types.jobs import PipelineDescription
+from google.cloud.dataflow_v1beta3.types.jobs import PubSubIODetails
+from google.cloud.dataflow_v1beta3.types.jobs import SdkVersion
+from google.cloud.dataflow_v1beta3.types.jobs import SnapshotJobRequest
+from google.cloud.dataflow_v1beta3.types.jobs import SpannerIODetails
+from google.cloud.dataflow_v1beta3.types.jobs import Step
+from google.cloud.dataflow_v1beta3.types.jobs import TransformSummary
+from google.cloud.dataflow_v1beta3.types.jobs import UpdateJobRequest
+from google.cloud.dataflow_v1beta3.types.jobs import JobState
+from google.cloud.dataflow_v1beta3.types.jobs import JobView
+from google.cloud.dataflow_v1beta3.types.jobs import KindType
+from google.cloud.dataflow_v1beta3.types.messages import AutoscalingEvent
+from google.cloud.dataflow_v1beta3.types.messages import JobMessage
+from google.cloud.dataflow_v1beta3.types.messages import ListJobMessagesRequest
+from google.cloud.dataflow_v1beta3.types.messages import ListJobMessagesResponse
+from google.cloud.dataflow_v1beta3.types.messages import StructuredMessage
+from google.cloud.dataflow_v1beta3.types.messages import JobMessageImportance
+from google.cloud.dataflow_v1beta3.types.metrics import GetJobExecutionDetailsRequest
+from google.cloud.dataflow_v1beta3.types.metrics import GetJobMetricsRequest
+from google.cloud.dataflow_v1beta3.types.metrics import GetStageExecutionDetailsRequest
+from google.cloud.dataflow_v1beta3.types.metrics import JobExecutionDetails
+from google.cloud.dataflow_v1beta3.types.metrics import JobMetrics
+from google.cloud.dataflow_v1beta3.types.metrics import MetricStructuredName
+from google.cloud.dataflow_v1beta3.types.metrics import MetricUpdate
+from google.cloud.dataflow_v1beta3.types.metrics import ProgressTimeseries
+from google.cloud.dataflow_v1beta3.types.metrics import StageExecutionDetails
+from google.cloud.dataflow_v1beta3.types.metrics import StageSummary
+from google.cloud.dataflow_v1beta3.types.metrics import WorkerDetails
+from google.cloud.dataflow_v1beta3.types.metrics import WorkItemDetails
+from google.cloud.dataflow_v1beta3.types.metrics import ExecutionState
+from google.cloud.dataflow_v1beta3.types.snapshots import DeleteSnapshotRequest
+from google.cloud.dataflow_v1beta3.types.snapshots import DeleteSnapshotResponse
+from google.cloud.dataflow_v1beta3.types.snapshots import GetSnapshotRequest
+from google.cloud.dataflow_v1beta3.types.snapshots import ListSnapshotsRequest
+from google.cloud.dataflow_v1beta3.types.snapshots import ListSnapshotsResponse
+from google.cloud.dataflow_v1beta3.types.snapshots import PubsubSnapshotMetadata
+from google.cloud.dataflow_v1beta3.types.snapshots import Snapshot
+from google.cloud.dataflow_v1beta3.types.snapshots import SnapshotState
+from google.cloud.dataflow_v1beta3.types.streaming import ComputationTopology
+from google.cloud.dataflow_v1beta3.types.streaming import CustomSourceLocation
+from google.cloud.dataflow_v1beta3.types.streaming import DataDiskAssignment
+from google.cloud.dataflow_v1beta3.types.streaming import KeyRangeDataDiskAssignment
+from google.cloud.dataflow_v1beta3.types.streaming import KeyRangeLocation
+from google.cloud.dataflow_v1beta3.types.streaming import MountedDataDisk
+from google.cloud.dataflow_v1beta3.types.streaming import PubsubLocation
+from google.cloud.dataflow_v1beta3.types.streaming import StateFamilyConfig
+from google.cloud.dataflow_v1beta3.types.streaming import (
+    StreamingApplianceSnapshotConfig,
+)
+from google.cloud.dataflow_v1beta3.types.streaming import StreamingComputationRanges
+from google.cloud.dataflow_v1beta3.types.streaming import StreamingSideInputLocation
+from google.cloud.dataflow_v1beta3.types.streaming import StreamingStageLocation
+from google.cloud.dataflow_v1beta3.types.streaming import StreamLocation
+from google.cloud.dataflow_v1beta3.types.streaming import TopologyConfig
+from google.cloud.dataflow_v1beta3.types.templates import ContainerSpec
+from google.cloud.dataflow_v1beta3.types.templates import CreateJobFromTemplateRequest
+from google.cloud.dataflow_v1beta3.types.templates import DynamicTemplateLaunchParams
+from google.cloud.dataflow_v1beta3.types.templates import FlexTemplateRuntimeEnvironment
+from google.cloud.dataflow_v1beta3.types.templates import GetTemplateRequest
+from google.cloud.dataflow_v1beta3.types.templates import GetTemplateResponse
+from google.cloud.dataflow_v1beta3.types.templates import InvalidTemplateParameters
+from google.cloud.dataflow_v1beta3.types.templates import LaunchFlexTemplateParameter
+from google.cloud.dataflow_v1beta3.types.templates import LaunchFlexTemplateRequest
+from google.cloud.dataflow_v1beta3.types.templates import LaunchFlexTemplateResponse
+from google.cloud.dataflow_v1beta3.types.templates import LaunchTemplateParameters
+from google.cloud.dataflow_v1beta3.types.templates import LaunchTemplateRequest
+from google.cloud.dataflow_v1beta3.types.templates import LaunchTemplateResponse
+from google.cloud.dataflow_v1beta3.types.templates import ParameterMetadata
+from google.cloud.dataflow_v1beta3.types.templates import RuntimeEnvironment
+from google.cloud.dataflow_v1beta3.types.templates import RuntimeMetadata
+from google.cloud.dataflow_v1beta3.types.templates import SDKInfo
+from google.cloud.dataflow_v1beta3.types.templates import TemplateMetadata
+from google.cloud.dataflow_v1beta3.types.templates import ParameterType
+
+__all__ = (
+    "FlexTemplatesServiceClient",
+    "FlexTemplatesServiceAsyncClient",
+    "JobsV1Beta3Client",
+    "JobsV1Beta3AsyncClient",
+    "MessagesV1Beta3Client",
+    "MessagesV1Beta3AsyncClient",
+    "MetricsV1Beta3Client",
+    "MetricsV1Beta3AsyncClient",
+    "SnapshotsV1Beta3Client",
+    "SnapshotsV1Beta3AsyncClient",
+    "TemplatesServiceClient",
+    "TemplatesServiceAsyncClient",
+    "AutoscalingSettings",
+    "DebugOptions",
+    "Disk",
+    "Environment",
+    "Package",
+    "SdkHarnessContainerImage",
+    "TaskRunnerSettings",
+    "WorkerPool",
+    "WorkerSettings",
+    "AutoscalingAlgorithm",
+    "DefaultPackageSet",
+    "FlexResourceSchedulingGoal",
+    "JobType",
+    "ShuffleMode",
+    "TeardownPolicy",
+    "WorkerIPAddressConfiguration",
+    "BigQueryIODetails",
+    "BigTableIODetails",
+    "CheckActiveJobsRequest",
+    "CheckActiveJobsResponse",
+    "CreateJobRequest",
+    "DatastoreIODetails",
+    "DisplayData",
+    "ExecutionStageState",
+    "ExecutionStageSummary",
+    "FailedLocation",
+    "FileIODetails",
+    "GetJobRequest",
+    "Job",
+    "JobExecutionInfo",
+    "JobExecutionStageInfo",
+    "JobMetadata",
+    "ListJobsRequest",
+    "ListJobsResponse",
+    "PipelineDescription",
+    "PubSubIODetails",
+    "SdkVersion",
+    "SnapshotJobRequest",
+    "SpannerIODetails",
+    "Step",
+    "TransformSummary",
+    "UpdateJobRequest",
+    "JobState",
+    "JobView",
+    "KindType",
+    "AutoscalingEvent",
+    "JobMessage",
+    "ListJobMessagesRequest",
+    "ListJobMessagesResponse",
+    "StructuredMessage",
+    "JobMessageImportance",
+    "GetJobExecutionDetailsRequest",
+    "GetJobMetricsRequest",
+    "GetStageExecutionDetailsRequest",
+    "JobExecutionDetails",
+    "JobMetrics",
+    "MetricStructuredName",
+    "MetricUpdate",
+    "ProgressTimeseries",
+    "StageExecutionDetails",
+    "StageSummary",
+    "WorkerDetails",
+    "WorkItemDetails",
+    "ExecutionState",
+    "DeleteSnapshotRequest",
+    "DeleteSnapshotResponse",
+    "GetSnapshotRequest",
+    "ListSnapshotsRequest",
+    "ListSnapshotsResponse",
+    "PubsubSnapshotMetadata",
+    "Snapshot",
+    "SnapshotState",
+    "ComputationTopology",
+    "CustomSourceLocation",
+    "DataDiskAssignment",
+    "KeyRangeDataDiskAssignment",
+    "KeyRangeLocation",
+    "MountedDataDisk",
+    "PubsubLocation",
+    "StateFamilyConfig",
+    "StreamingApplianceSnapshotConfig",
+    "StreamingComputationRanges",
+    "StreamingSideInputLocation",
+    "StreamingStageLocation",
+    "StreamLocation",
+    "TopologyConfig",
+    "ContainerSpec",
+    "CreateJobFromTemplateRequest",
+    "DynamicTemplateLaunchParams",
+    "FlexTemplateRuntimeEnvironment",
+    "GetTemplateRequest",
+    "GetTemplateResponse",
+    "InvalidTemplateParameters",
+    "LaunchFlexTemplateParameter",
+    "LaunchFlexTemplateRequest",
+    "LaunchFlexTemplateResponse",
+    "LaunchTemplateParameters",
+    "LaunchTemplateRequest",
+    "LaunchTemplateResponse",
+    "ParameterMetadata",
+    "RuntimeEnvironment",
+    "RuntimeMetadata",
+    "SDKInfo",
+    "TemplateMetadata",
+    "ParameterType",
+)

packages/google-cloud-dataflow-client/google/cloud/dataflow/py.typed

@@ -0,0 +1,2 @@
+# Marker file for PEP 561.
+# The google-cloud-dataflow package uses inline types.