Skip to content
This repository has been archived by the owner on Oct 31, 2023. It is now read-only.

Commit

Permalink
chore: use gapic-generator-python 0.51.2 (#34)
Browse files Browse the repository at this point in the history
- [ ] Regenerate this pull request now.

fix: add 'dict' annotation type to 'request'

Committer: @busunkim96
PiperOrigin-RevId: 398509016

Source-Link: googleapis/googleapis@b224dfa

Source-Link: googleapis/googleapis-gen@63a1db7
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNjNhMWRiN2EzOGQ3NGI5NjM5NTkyZjUyMWVkMWRhYWY3Mjk5YWQ5YSJ9
  • Loading branch information
gcf-owl-bot[bot] committed Sep 24, 2021
1 parent 584e58c commit db5d966
Show file tree
Hide file tree
Showing 25 changed files with 103 additions and 103 deletions.
Expand Up @@ -17,7 +17,7 @@
from distutils import util
import os
import re
from typing import Callable, Dict, Optional, Sequence, Tuple, Type, Union
from typing import Dict, Optional, Sequence, Tuple, Type, Union
import pkg_resources

from google.api_core import client_options as client_options_lib # type: ignore
Expand Down Expand Up @@ -340,7 +340,7 @@ def __init__(

def launch_flex_template(
self,
request: templates.LaunchFlexTemplateRequest = None,
request: Union[templates.LaunchFlexTemplateRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
Expand All @@ -349,7 +349,7 @@ def launch_flex_template(
r"""Launch a job with a FlexTemplate.
Args:
request (google.cloud.dataflow_v1beta3.types.LaunchFlexTemplateRequest):
request (Union[google.cloud.dataflow_v1beta3.types.LaunchFlexTemplateRequest, dict]):
The request object. A request to launch a Cloud Dataflow
job from a FlexTemplate.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
Expand Down
Expand Up @@ -122,7 +122,7 @@ def __init__(
**scopes_kwargs, quota_project_id=quota_project_id
)

# If the credentials is service account credentials, then always try to use self signed JWT.
# If the credentials are service account credentials, then always try to use self signed JWT.
if (
always_use_jwt_access
and isinstance(credentials, service_account.Credentials)
Expand Down
Expand Up @@ -81,16 +81,16 @@ def __init__(
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
If provided, it overrides the ``host`` argument and tries to create
a mutual TLS channel with client SSL credentials from
``client_cert_source`` or applicatin default SSL credentials.
``client_cert_source`` or application default SSL credentials.
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
Deprecated. A callback to provide client SSL certificate bytes and
private key bytes, both in PEM format. It is ignored if
``api_mtls_endpoint`` is None.
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
for grpc channel. It is ignored if ``channel`` is provided.
for the grpc channel. It is ignored if ``channel`` is provided.
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
A callback to provide client certificate bytes and private key bytes,
both in PEM format. It is used to configure mutual TLS channel. It is
both in PEM format. It is used to configure a mutual TLS channel. It is
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
quota_project_id (Optional[str]): An optional project to use for billing
and quota.
Expand Down
Expand Up @@ -128,16 +128,16 @@ def __init__(
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
If provided, it overrides the ``host`` argument and tries to create
a mutual TLS channel with client SSL credentials from
``client_cert_source`` or applicatin default SSL credentials.
``client_cert_source`` or application default SSL credentials.
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
Deprecated. A callback to provide client SSL certificate bytes and
private key bytes, both in PEM format. It is ignored if
``api_mtls_endpoint`` is None.
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
for grpc channel. It is ignored if ``channel`` is provided.
for the grpc channel. It is ignored if ``channel`` is provided.
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
A callback to provide client certificate bytes and private key bytes,
both in PEM format. It is used to configure mutual TLS channel. It is
both in PEM format. It is used to configure a mutual TLS channel. It is
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
quota_project_id (Optional[str]): An optional project to use for billing
and quota.
Expand Down
30 changes: 15 additions & 15 deletions google/cloud/dataflow_v1beta3/services/jobs_v1_beta3/client.py
Expand Up @@ -17,7 +17,7 @@
from distutils import util
import os
import re
from typing import Callable, Dict, Optional, Sequence, Tuple, Type, Union
from typing import Dict, Optional, Sequence, Tuple, Type, Union
import pkg_resources

from google.api_core import client_options as client_options_lib # type: ignore
Expand Down Expand Up @@ -341,7 +341,7 @@ def __init__(

def create_job(
self,
request: jobs.CreateJobRequest = None,
request: Union[jobs.CreateJobRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
Expand All @@ -356,7 +356,7 @@ def create_job(
will always start in ``us-central1``.
Args:
request (google.cloud.dataflow_v1beta3.types.CreateJobRequest):
request (Union[google.cloud.dataflow_v1beta3.types.CreateJobRequest, dict]):
The request object. Request to create a Cloud Dataflow
job.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
Expand Down Expand Up @@ -391,7 +391,7 @@ def create_job(

def get_job(
self,
request: jobs.GetJobRequest = None,
request: Union[jobs.GetJobRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
Expand All @@ -406,7 +406,7 @@ def get_job(
get the state of jobs that are running in ``us-central1``.
Args:
request (google.cloud.dataflow_v1beta3.types.GetJobRequest):
request (Union[google.cloud.dataflow_v1beta3.types.GetJobRequest, dict]):
The request object. Request to get the state of a Cloud
Dataflow job.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
Expand Down Expand Up @@ -441,7 +441,7 @@ def get_job(

def update_job(
self,
request: jobs.UpdateJobRequest = None,
request: Union[jobs.UpdateJobRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
Expand All @@ -457,7 +457,7 @@ def update_job(
``us-central1``.
Args:
request (google.cloud.dataflow_v1beta3.types.UpdateJobRequest):
request (Union[google.cloud.dataflow_v1beta3.types.UpdateJobRequest, dict]):
The request object. Request to update a Cloud Dataflow
job.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
Expand Down Expand Up @@ -492,7 +492,7 @@ def update_job(

def list_jobs(
self,
request: jobs.ListJobsRequest = None,
request: Union[jobs.ListJobsRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
Expand All @@ -509,7 +509,7 @@ def list_jobs(
running in ``us-central1``.
Args:
request (google.cloud.dataflow_v1beta3.types.ListJobsRequest):
request (Union[google.cloud.dataflow_v1beta3.types.ListJobsRequest, dict]):
The request object. Request to list Cloud Dataflow jobs.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
Expand Down Expand Up @@ -559,7 +559,7 @@ def list_jobs(

def aggregated_list_jobs(
self,
request: jobs.ListJobsRequest = None,
request: Union[jobs.ListJobsRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
Expand All @@ -568,7 +568,7 @@ def aggregated_list_jobs(
r"""List the jobs of a project across all regions.
Args:
request (google.cloud.dataflow_v1beta3.types.ListJobsRequest):
request (Union[google.cloud.dataflow_v1beta3.types.ListJobsRequest, dict]):
The request object. Request to list Cloud Dataflow jobs.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
Expand Down Expand Up @@ -618,7 +618,7 @@ def aggregated_list_jobs(

def check_active_jobs(
self,
request: jobs.CheckActiveJobsRequest = None,
request: Union[jobs.CheckActiveJobsRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
Expand All @@ -628,7 +628,7 @@ def check_active_jobs(
project across all regions.
Args:
request (google.cloud.dataflow_v1beta3.types.CheckActiveJobsRequest):
request (Union[google.cloud.dataflow_v1beta3.types.CheckActiveJobsRequest, dict]):
The request object. Request to check is active jobs
exists for a project
retry (google.api_core.retry.Retry): Designation of what errors, if any,
Expand Down Expand Up @@ -661,7 +661,7 @@ def check_active_jobs(

def snapshot_job(
self,
request: jobs.SnapshotJobRequest = None,
request: Union[jobs.SnapshotJobRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
Expand All @@ -670,7 +670,7 @@ def snapshot_job(
r"""Snapshot the state of a streaming job.
Args:
request (google.cloud.dataflow_v1beta3.types.SnapshotJobRequest):
request (Union[google.cloud.dataflow_v1beta3.types.SnapshotJobRequest, dict]):
The request object. Request to create a snapshot of a
job.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
Expand Down
Expand Up @@ -123,7 +123,7 @@ def __init__(
**scopes_kwargs, quota_project_id=quota_project_id
)

# If the credentials is service account credentials, then always try to use self signed JWT.
# If the credentials are service account credentials, then always try to use self signed JWT.
if (
always_use_jwt_access
and isinstance(credentials, service_account.Credentials)
Expand Down
Expand Up @@ -83,16 +83,16 @@ def __init__(
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
If provided, it overrides the ``host`` argument and tries to create
a mutual TLS channel with client SSL credentials from
``client_cert_source`` or applicatin default SSL credentials.
``client_cert_source`` or application default SSL credentials.
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
Deprecated. A callback to provide client SSL certificate bytes and
private key bytes, both in PEM format. It is ignored if
``api_mtls_endpoint`` is None.
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
for grpc channel. It is ignored if ``channel`` is provided.
for the grpc channel. It is ignored if ``channel`` is provided.
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
A callback to provide client certificate bytes and private key bytes,
both in PEM format. It is used to configure mutual TLS channel. It is
both in PEM format. It is used to configure a mutual TLS channel. It is
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
quota_project_id (Optional[str]): An optional project to use for billing
and quota.
Expand Down
Expand Up @@ -130,16 +130,16 @@ def __init__(
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
If provided, it overrides the ``host`` argument and tries to create
a mutual TLS channel with client SSL credentials from
``client_cert_source`` or applicatin default SSL credentials.
``client_cert_source`` or application default SSL credentials.
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
Deprecated. A callback to provide client SSL certificate bytes and
private key bytes, both in PEM format. It is ignored if
``api_mtls_endpoint`` is None.
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
for grpc channel. It is ignored if ``channel`` is provided.
for the grpc channel. It is ignored if ``channel`` is provided.
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
A callback to provide client certificate bytes and private key bytes,
both in PEM format. It is used to configure mutual TLS channel. It is
both in PEM format. It is used to configure a mutual TLS channel. It is
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
quota_project_id (Optional[str]): An optional project to use for billing
and quota.
Expand Down
Expand Up @@ -17,7 +17,7 @@
from distutils import util
import os
import re
from typing import Callable, Dict, Optional, Sequence, Tuple, Type, Union
from typing import Dict, Optional, Sequence, Tuple, Type, Union
import pkg_resources

from google.api_core import client_options as client_options_lib # type: ignore
Expand Down Expand Up @@ -338,7 +338,7 @@ def __init__(

def list_job_messages(
self,
request: messages.ListJobMessagesRequest = None,
request: Union[messages.ListJobMessagesRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
Expand All @@ -355,7 +355,7 @@ def list_job_messages(
``us-central1``.
Args:
request (google.cloud.dataflow_v1beta3.types.ListJobMessagesRequest):
request (Union[google.cloud.dataflow_v1beta3.types.ListJobMessagesRequest, dict]):
The request object. Request to list job messages.
Up to max_results messages will be returned in the time
range specified starting with the oldest messages first.
Expand Down
Expand Up @@ -122,7 +122,7 @@ def __init__(
**scopes_kwargs, quota_project_id=quota_project_id
)

# If the credentials is service account credentials, then always try to use self signed JWT.
# If the credentials are service account credentials, then always try to use self signed JWT.
if (
always_use_jwt_access
and isinstance(credentials, service_account.Credentials)
Expand Down
Expand Up @@ -81,16 +81,16 @@ def __init__(
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
If provided, it overrides the ``host`` argument and tries to create
a mutual TLS channel with client SSL credentials from
``client_cert_source`` or applicatin default SSL credentials.
``client_cert_source`` or application default SSL credentials.
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
Deprecated. A callback to provide client SSL certificate bytes and
private key bytes, both in PEM format. It is ignored if
``api_mtls_endpoint`` is None.
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
for grpc channel. It is ignored if ``channel`` is provided.
for the grpc channel. It is ignored if ``channel`` is provided.
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
A callback to provide client certificate bytes and private key bytes,
both in PEM format. It is used to configure mutual TLS channel. It is
both in PEM format. It is used to configure a mutual TLS channel. It is
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
quota_project_id (Optional[str]): An optional project to use for billing
and quota.
Expand Down
Expand Up @@ -128,16 +128,16 @@ def __init__(
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
If provided, it overrides the ``host`` argument and tries to create
a mutual TLS channel with client SSL credentials from
``client_cert_source`` or applicatin default SSL credentials.
``client_cert_source`` or application default SSL credentials.
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
Deprecated. A callback to provide client SSL certificate bytes and
private key bytes, both in PEM format. It is ignored if
``api_mtls_endpoint`` is None.
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
for grpc channel. It is ignored if ``channel`` is provided.
for the grpc channel. It is ignored if ``channel`` is provided.
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
A callback to provide client certificate bytes and private key bytes,
both in PEM format. It is used to configure mutual TLS channel. It is
both in PEM format. It is used to configure a mutual TLS channel. It is
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
quota_project_id (Optional[str]): An optional project to use for billing
and quota.
Expand Down

0 comments on commit db5d966

Please sign in to comment.