Skip to content
This repository was archived by the owner on Jul 6, 2023. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
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 @@ -371,7 +371,7 @@ def __init__(

def list_executions(
self,
request: executions.ListExecutionsRequest = None,
request: Union[executions.ListExecutionsRequest, dict] = None,
*,
parent: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -385,7 +385,7 @@ def list_executions(
first).

Args:
request (google.cloud.workflows.executions_v1.types.ListExecutionsRequest):
request (Union[google.cloud.workflows.executions_v1.types.ListExecutionsRequest, dict]):
The request object. Request for the
[ListExecutions][]
method.
Expand Down Expand Up @@ -459,7 +459,7 @@ def list_executions(

def create_execution(
self,
request: executions.CreateExecutionRequest = None,
request: Union[executions.CreateExecutionRequest, dict] = None,
*,
parent: str = None,
execution: executions.Execution = None,
Expand All @@ -471,7 +471,7 @@ def create_execution(
the given workflow.

Args:
request (google.cloud.workflows.executions_v1.types.CreateExecutionRequest):
request (Union[google.cloud.workflows.executions_v1.types.CreateExecutionRequest, dict]):
The request object. Request for the
[CreateExecution][google.cloud.workflows.executions.v1.Executions.CreateExecution]
method.
Expand Down Expand Up @@ -544,7 +544,7 @@ def create_execution(

def get_execution(
self,
request: executions.GetExecutionRequest = None,
request: Union[executions.GetExecutionRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -554,7 +554,7 @@ def get_execution(
r"""Returns an execution of the given name.

Args:
request (google.cloud.workflows.executions_v1.types.GetExecutionRequest):
request (Union[google.cloud.workflows.executions_v1.types.GetExecutionRequest, dict]):
The request object. Request for the
[GetExecution][google.cloud.workflows.executions.v1.Executions.GetExecution]
method.
Expand Down Expand Up @@ -617,7 +617,7 @@ def get_execution(

def cancel_execution(
self,
request: executions.CancelExecutionRequest = None,
request: Union[executions.CancelExecutionRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -627,7 +627,7 @@ def cancel_execution(
r"""Cancels an execution of the given name.

Args:
request (google.cloud.workflows.executions_v1.types.CancelExecutionRequest):
request (Union[google.cloud.workflows.executions_v1.types.CancelExecutionRequest, dict]):
The request object. Request for the
[CancelExecution][google.cloud.workflows.executions.v1.Executions.CancelExecution]
method.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,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
Original file line number Diff line number Diff line change
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
Original file line number Diff line number Diff line change
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
Original file line number Diff line number Diff line change
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 @@ -372,7 +372,7 @@ def __init__(

def list_executions(
self,
request: executions.ListExecutionsRequest = None,
request: Union[executions.ListExecutionsRequest, dict] = None,
*,
parent: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -386,7 +386,7 @@ def list_executions(
first).

Args:
request (google.cloud.workflows.executions_v1beta.types.ListExecutionsRequest):
request (Union[google.cloud.workflows.executions_v1beta.types.ListExecutionsRequest, dict]):
The request object. Request for the
[ListExecutions][google.cloud.workflows.executions.v1beta.Executions.ListExecutions]
method.
Expand Down Expand Up @@ -460,7 +460,7 @@ def list_executions(

def create_execution(
self,
request: executions.CreateExecutionRequest = None,
request: Union[executions.CreateExecutionRequest, dict] = None,
*,
parent: str = None,
execution: executions.Execution = None,
Expand All @@ -472,7 +472,7 @@ def create_execution(
the given workflow.

Args:
request (google.cloud.workflows.executions_v1beta.types.CreateExecutionRequest):
request (Union[google.cloud.workflows.executions_v1beta.types.CreateExecutionRequest, dict]):
The request object. Request for the
[CreateExecution][google.cloud.workflows.executions.v1beta.Executions.CreateExecution]
method.
Expand Down Expand Up @@ -545,7 +545,7 @@ def create_execution(

def get_execution(
self,
request: executions.GetExecutionRequest = None,
request: Union[executions.GetExecutionRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -555,7 +555,7 @@ def get_execution(
r"""Returns an execution of the given name.

Args:
request (google.cloud.workflows.executions_v1beta.types.GetExecutionRequest):
request (Union[google.cloud.workflows.executions_v1beta.types.GetExecutionRequest, dict]):
The request object. Request for the
[GetExecution][google.cloud.workflows.executions.v1beta.Executions.GetExecution]
method.
Expand Down Expand Up @@ -618,7 +618,7 @@ def get_execution(

def cancel_execution(
self,
request: executions.CancelExecutionRequest = None,
request: Union[executions.CancelExecutionRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -628,7 +628,7 @@ def cancel_execution(
r"""Cancels an execution of the given name.

Args:
request (google.cloud.workflows.executions_v1beta.types.CancelExecutionRequest):
request (Union[google.cloud.workflows.executions_v1beta.types.CancelExecutionRequest, dict]):
The request object. Request for the
[CancelExecution][google.cloud.workflows.executions.v1beta.Executions.CancelExecution]
method.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,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
Original file line number Diff line number Diff line change
Expand Up @@ -82,16 +82,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
Original file line number Diff line number Diff line change
Expand Up @@ -129,16 +129,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
22 changes: 11 additions & 11 deletions google/cloud/workflows_v1/services/workflows/client.py
Original file line number Diff line number Diff line change
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 @@ -358,7 +358,7 @@ def __init__(

def list_workflows(
self,
request: workflows.ListWorkflowsRequest = None,
request: Union[workflows.ListWorkflowsRequest, dict] = None,
*,
parent: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -369,7 +369,7 @@ def list_workflows(
The default order is not specified.

Args:
request (google.cloud.workflows_v1.types.ListWorkflowsRequest):
request (Union[google.cloud.workflows_v1.types.ListWorkflowsRequest, dict]):
The request object. Request for the
[ListWorkflows][google.cloud.workflows.v1.Workflows.ListWorkflows]
method.
Expand Down Expand Up @@ -443,7 +443,7 @@ def list_workflows(

def get_workflow(
self,
request: workflows.GetWorkflowRequest = None,
request: Union[workflows.GetWorkflowRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -453,7 +453,7 @@ def get_workflow(
r"""Gets details of a single Workflow.

Args:
request (google.cloud.workflows_v1.types.GetWorkflowRequest):
request (Union[google.cloud.workflows_v1.types.GetWorkflowRequest, dict]):
The request object. Request for the
[GetWorkflow][google.cloud.workflows.v1.Workflows.GetWorkflow]
method.
Expand Down Expand Up @@ -516,7 +516,7 @@ def get_workflow(

def create_workflow(
self,
request: workflows.CreateWorkflowRequest = None,
request: Union[workflows.CreateWorkflowRequest, dict] = None,
*,
parent: str = None,
workflow: workflows.Workflow = None,
Expand All @@ -531,7 +531,7 @@ def create_workflow(
[ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.

Args:
request (google.cloud.workflows_v1.types.CreateWorkflowRequest):
request (Union[google.cloud.workflows_v1.types.CreateWorkflowRequest, dict]):
The request object. Request for the
[CreateWorkflow][google.cloud.workflows.v1.Workflows.CreateWorkflow]
method.
Expand Down Expand Up @@ -630,7 +630,7 @@ def create_workflow(

def delete_workflow(
self,
request: workflows.DeleteWorkflowRequest = None,
request: Union[workflows.DeleteWorkflowRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -642,7 +642,7 @@ def delete_workflow(
executions of the workflow.

Args:
request (google.cloud.workflows_v1.types.DeleteWorkflowRequest):
request (Union[google.cloud.workflows_v1.types.DeleteWorkflowRequest, dict]):
The request object. Request for the
[DeleteWorkflow][google.cloud.workflows.v1.Workflows.DeleteWorkflow]
method.
Expand Down Expand Up @@ -726,7 +726,7 @@ def delete_workflow(

def update_workflow(
self,
request: workflows.UpdateWorkflowRequest = None,
request: Union[workflows.UpdateWorkflowRequest, dict] = None,
*,
workflow: workflows.Workflow = None,
update_mask: field_mask_pb2.FieldMask = None,
Expand All @@ -742,7 +742,7 @@ def update_workflow(
used in new workflow executions.

Args:
request (google.cloud.workflows_v1.types.UpdateWorkflowRequest):
request (Union[google.cloud.workflows_v1.types.UpdateWorkflowRequest, dict]):
The request object. Request for the
[UpdateWorkflow][google.cloud.workflows.v1.Workflows.UpdateWorkflow]
method.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,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
Original file line number Diff line number Diff line change
Expand Up @@ -84,16 +84,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
Loading