Package Methods (1.18.1)

ExecutionsAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.workflows.executions_v1.services.executions.transports.base.ExecutionsTransport, typing.Callable[[...], google.cloud.workflows.executions_v1.services.executions.transports.base.ExecutionsTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = 

cancel_execution( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1.types.executions.CancelExecutionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows.executions_v1.types.executions.Execution

common_billing_account_path(billing_account: str) -> str

common_folder_path(folder: str) -> str

common_location_path(project: str, location: str) -> str

common_organization_path(organization: str) -> str

common_project_path(project: str) -> str

create_execution( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1.types.executions.CreateExecutionRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, execution: typing.Optional[ google.cloud.workflows.executions_v1.types.executions.Execution ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows.executions_v1.types.executions.Execution

execution_path(project: str, location: str, workflow: str, execution: str) -> str

from_service_account_file(filename: str, *args, **kwargs)

from_service_account_info(info: dict, *args, **kwargs)

from_service_account_json(filename: str, *args, **kwargs)

get_execution( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1.types.executions.GetExecutionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows.executions_v1.types.executions.Execution

get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )

get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.workflows.executions_v1.services.executions.transports.base.ExecutionsTransport ]

list_executions( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1.types.executions.ListExecutionsRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.workflows.executions_v1.services.executions.pagers.ListExecutionsAsyncPager )

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

parse_common_folder_path(path: str) -> typing.Dict[str, str]

parse_common_location_path(path: str) -> typing.Dict[str, str]

parse_common_organization_path(path: str) -> typing.Dict[str, str]

parse_common_project_path(path: str) -> typing.Dict[str, str]

parse_execution_path(path: str) -> typing.Dict[str, str]

parse_workflow_path(path: str) -> typing.Dict[str, str]

workflow_path(project: str, location: str, workflow: str) -> str

ExecutionsClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.workflows.executions_v1.services.executions.transports.base.ExecutionsTransport, typing.Callable[[...], google.cloud.workflows.executions_v1.services.executions.transports.base.ExecutionsTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = 

__exit__(type, value, traceback)

cancel_execution( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1.types.executions.CancelExecutionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows.executions_v1.types.executions.Execution

common_billing_account_path(billing_account: str) -> str

common_folder_path(folder: str) -> str

common_location_path(project: str, location: str) -> str

common_organization_path(organization: str) -> str

common_project_path(project: str) -> str

create_execution( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1.types.executions.CreateExecutionRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, execution: typing.Optional[ google.cloud.workflows.executions_v1.types.executions.Execution ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows.executions_v1.types.executions.Execution

execution_path(project: str, location: str, workflow: str, execution: str) -> str

from_service_account_file(filename: str, *args, **kwargs)

from_service_account_info(info: dict, *args, **kwargs)

from_service_account_json(filename: str, *args, **kwargs)

get_execution( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1.types.executions.GetExecutionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows.executions_v1.types.executions.Execution

get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )

list_executions( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1.types.executions.ListExecutionsRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.workflows.executions_v1.services.executions.pagers.ListExecutionsPager )

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

parse_common_folder_path(path: str) -> typing.Dict[str, str]

parse_common_location_path(path: str) -> typing.Dict[str, str]

parse_common_organization_path(path: str) -> typing.Dict[str, str]

parse_common_project_path(path: str) -> typing.Dict[str, str]

parse_execution_path(path: str) -> typing.Dict[str, str]

parse_workflow_path(path: str) -> typing.Dict[str, str]

workflow_path(project: str, location: str, workflow: str) -> str

ListExecutionsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.workflows.executions_v1.types.executions.ListExecutionsResponse ], ], request: google.cloud.workflows.executions_v1.types.executions.ListExecutionsRequest, response: google.cloud.workflows.executions_v1.types.executions.ListExecutionsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )

ListExecutionsPager( method: typing.Callable[ [...], google.cloud.workflows.executions_v1.types.executions.ListExecutionsResponse, ], request: google.cloud.workflows.executions_v1.types.executions.ListExecutionsRequest, response: google.cloud.workflows.executions_v1.types.executions.ListExecutionsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )

ExecutionsAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.workflows.executions_v1beta.services.executions.transports.base.ExecutionsTransport, typing.Callable[[...], google.cloud.workflows.executions_v1beta.services.executions.transports.base.ExecutionsTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = 

cancel_execution( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1beta.types.executions.CancelExecutionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows.executions_v1beta.types.executions.Execution

common_billing_account_path(billing_account: str) -> str

common_folder_path(folder: str) -> str

common_location_path(project: str, location: str) -> str

common_organization_path(organization: str) -> str

common_project_path(project: str) -> str

create_execution( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1beta.types.executions.CreateExecutionRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, execution: typing.Optional[ google.cloud.workflows.executions_v1beta.types.executions.Execution ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows.executions_v1beta.types.executions.Execution

execution_path(project: str, location: str, workflow: str, execution: str) -> str

from_service_account_file(filename: str, *args, **kwargs)

from_service_account_info(info: dict, *args, **kwargs)

from_service_account_json(filename: str, *args, **kwargs)

get_execution( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1beta.types.executions.GetExecutionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows.executions_v1beta.types.executions.Execution

get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )

get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.workflows.executions_v1beta.services.executions.transports.base.ExecutionsTransport ]

list_executions( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1beta.types.executions.ListExecutionsRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.workflows.executions_v1beta.services.executions.pagers.ListExecutionsAsyncPager )

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

parse_common_folder_path(path: str) -> typing.Dict[str, str]

parse_common_location_path(path: str) -> typing.Dict[str, str]

parse_common_organization_path(path: str) -> typing.Dict[str, str]

parse_common_project_path(path: str) -> typing.Dict[str, str]

parse_execution_path(path: str) -> typing.Dict[str, str]

parse_workflow_path(path: str) -> typing.Dict[str, str]

workflow_path(project: str, location: str, workflow: str) -> str

ExecutionsClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.workflows.executions_v1beta.services.executions.transports.base.ExecutionsTransport, typing.Callable[[...], google.cloud.workflows.executions_v1beta.services.executions.transports.base.ExecutionsTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = 

__exit__(type, value, traceback)

cancel_execution( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1beta.types.executions.CancelExecutionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows.executions_v1beta.types.executions.Execution

common_billing_account_path(billing_account: str) -> str

common_folder_path(folder: str) -> str

common_location_path(project: str, location: str) -> str

common_organization_path(organization: str) -> str

common_project_path(project: str) -> str

create_execution( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1beta.types.executions.CreateExecutionRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, execution: typing.Optional[ google.cloud.workflows.executions_v1beta.types.executions.Execution ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows.executions_v1beta.types.executions.Execution

execution_path(project: str, location: str, workflow: str, execution: str) -> str

from_service_account_file(filename: str, *args, **kwargs)

from_service_account_info(info: dict, *args, **kwargs)

from_service_account_json(filename: str, *args, **kwargs)

get_execution( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1beta.types.executions.GetExecutionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows.executions_v1beta.types.executions.Execution

get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )

list_executions( request: typing.Optional[ typing.Union[ google.cloud.workflows.executions_v1beta.types.executions.ListExecutionsRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.workflows.executions_v1beta.services.executions.pagers.ListExecutionsPager )

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

parse_common_folder_path(path: str) -> typing.Dict[str, str]

parse_common_location_path(path: str) -> typing.Dict[str, str]

parse_common_organization_path(path: str) -> typing.Dict[str, str]

parse_common_project_path(path: str) -> typing.Dict[str, str]

parse_execution_path(path: str) -> typing.Dict[str, str]

parse_workflow_path(path: str) -> typing.Dict[str, str]

workflow_path(project: str, location: str, workflow: str) -> str

ListExecutionsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.workflows.executions_v1beta.types.executions.ListExecutionsResponse ], ], request: google.cloud.workflows.executions_v1beta.types.executions.ListExecutionsRequest, response: google.cloud.workflows.executions_v1beta.types.executions.ListExecutionsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )

ListExecutionsPager( method: typing.Callable[ [...], google.cloud.workflows.executions_v1beta.types.executions.ListExecutionsResponse, ], request: google.cloud.workflows.executions_v1beta.types.executions.ListExecutionsRequest, response: google.cloud.workflows.executions_v1beta.types.executions.ListExecutionsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )

WorkflowsAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.workflows_v1.services.workflows.transports.base.WorkflowsTransport, typing.Callable[[...], google.cloud.workflows_v1.services.workflows.transports.base.WorkflowsTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = 

common_billing_account_path(billing_account: str) -> str

common_folder_path(folder: str) -> str

common_location_path(project: str, location: str) -> str

common_organization_path(organization: str) -> str

common_project_path(project: str) -> str

create_workflow( request: typing.Optional[ typing.Union[ google.cloud.workflows_v1.types.workflows.CreateWorkflowRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, workflow: typing.Optional[ google.cloud.workflows_v1.types.workflows.Workflow ] = None, workflow_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation

crypto_key_path(project: str, location: str, keyRing: str, cryptoKey: str) -> str

crypto_key_version_path( project: str, location: str, keyRing: str, cryptoKey: str, cryptoKeyVersion: str ) -> str

delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> None

delete_workflow( request: typing.Optional[ typing.Union[ google.cloud.workflows_v1.types.workflows.DeleteWorkflowRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation

from_service_account_file(filename: str, *args, **kwargs)

from_service_account_info(info: dict, *args, **kwargs)

from_service_account_json(filename: str, *args, **kwargs)

get_location( request: typing.Optional[ google.cloud.location.locations_pb2.GetLocationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.location.locations_pb2.Location

get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )

get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.Operation

get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.workflows_v1.services.workflows.transports.base.WorkflowsTransport ]

get_workflow( request: typing.Optional[ typing.Union[google.cloud.workflows_v1.types.workflows.GetWorkflowRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows_v1.types.workflows.Workflow

list_locations( request: typing.Optional[ google.cloud.location.locations_pb2.ListLocationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.location.locations_pb2.ListLocationsResponse

list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponse

list_workflow_revisions( request: typing.Optional[ typing.Union[ google.cloud.workflows_v1.types.workflows.ListWorkflowRevisionsRequest, dict ] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.workflows_v1.services.workflows.pagers.ListWorkflowRevisionsAsyncPager )

list_workflows( request: typing.Optional[ typing.Union[ google.cloud.workflows_v1.types.workflows.ListWorkflowsRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.workflows_v1.services.workflows.pagers.ListWorkflowsAsyncPager

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

parse_common_folder_path(path: str) -> typing.Dict[str, str]

parse_common_location_path(path: str) -> typing.Dict[str, str]

parse_common_organization_path(path: str) -> typing.Dict[str, str]

parse_common_project_path(path: str) -> typing.Dict[str, str]

parse_crypto_key_path(path: str) -> typing.Dict[str, str]

parse_crypto_key_version_path(path: str) -> typing.Dict[str, str]

parse_workflow_path(path: str) -> typing.Dict[str, str]

update_workflow( request: typing.Optional[ typing.Union[ google.cloud.workflows_v1.types.workflows.UpdateWorkflowRequest, dict ] ] = None, *, workflow: typing.Optional[ google.cloud.workflows_v1.types.workflows.Workflow ] = None, update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation

workflow_path(project: str, location: str, workflow: str) -> str

WorkflowsClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.workflows_v1.services.workflows.transports.base.WorkflowsTransport, typing.Callable[[...], google.cloud.workflows_v1.services.workflows.transports.base.WorkflowsTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = 

__exit__(type, value, traceback)

common_billing_account_path(billing_account: str) -> str

common_folder_path(folder: str) -> str

common_location_path(project: str, location: str) -> str

common_organization_path(organization: str) -> str

common_project_path(project: str) -> str

create_workflow( request: typing.Optional[ typing.Union[ google.cloud.workflows_v1.types.workflows.CreateWorkflowRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, workflow: typing.Optional[ google.cloud.workflows_v1.types.workflows.Workflow ] = None, workflow_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation