Skip to content
Closed
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 @@ -484,9 +484,8 @@ def create_instance(
request.instance_id = instance_id
if instance is not None:
request.instance = instance

if clusters:
request.clusters.update(clusters)
if clusters is not None:
request.clusters = clusters

# Wrap the RPC method; this adds retry and timeout information,
# and friendly error handling.
Expand Down Expand Up @@ -1832,6 +1831,9 @@ def get_iam_policy(
elif not request:
request = iam_policy.GetIamPolicyRequest(resource=resource,)

if resource is not None:
request.resource = resource

# Wrap the RPC method; this adds retry and timeout information,
# and friendly error handling.
rpc = self._transport._wrapped_methods[self._transport.get_iam_policy]
Expand Down Expand Up @@ -1957,6 +1959,9 @@ def set_iam_policy(
elif not request:
request = iam_policy.SetIamPolicyRequest(resource=resource,)

if resource is not None:
request.resource = resource

# Wrap the RPC method; this adds retry and timeout information,
# and friendly error handling.
rpc = self._transport._wrapped_methods[self._transport.set_iam_policy]
Expand Down Expand Up @@ -2039,6 +2044,12 @@ def test_iam_permissions(
resource=resource, permissions=permissions,
)

if resource is not None:
request.resource = resource

if permissions:
request.permissions.extend(permissions)

# Wrap the RPC method; this adds retry and timeout information,
# and friendly error handling.
rpc = self._transport._wrapped_methods[self._transport.test_iam_permissions]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,16 @@
# limitations under the License.
#

from typing import Any, AsyncIterable, Awaitable, Callable, Iterable, Sequence, Tuple
from typing import (
Any,
AsyncIterable,
Awaitable,
Callable,
Iterable,
Sequence,
Tuple,
Optional,
)

from google.cloud.bigtable_admin_v2.types import bigtable_instance_admin
from google.cloud.bigtable_admin_v2.types import instance
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -952,9 +952,8 @@ def modify_column_families(

if name is not None:
request.name = name

if modifications:
request.modifications.extend(modifications)
if modifications is not None:
request.modifications = modifications

# Wrap the RPC method; this adds retry and timeout information,
# and friendly error handling.
Expand Down Expand Up @@ -2236,6 +2235,9 @@ def get_iam_policy(
elif not request:
request = iam_policy.GetIamPolicyRequest(resource=resource,)

if resource is not None:
request.resource = resource

# Wrap the RPC method; this adds retry and timeout information,
# and friendly error handling.
rpc = self._transport._wrapped_methods[self._transport.get_iam_policy]
Expand Down Expand Up @@ -2361,6 +2363,9 @@ def set_iam_policy(
elif not request:
request = iam_policy.SetIamPolicyRequest(resource=resource,)

if resource is not None:
request.resource = resource

# Wrap the RPC method; this adds retry and timeout information,
# and friendly error handling.
rpc = self._transport._wrapped_methods[self._transport.set_iam_policy]
Expand Down Expand Up @@ -2443,6 +2448,12 @@ def test_iam_permissions(
resource=resource, permissions=permissions,
)

if resource is not None:
request.resource = resource

if permissions:
request.permissions.extend(permissions)

# Wrap the RPC method; this adds retry and timeout information,
# and friendly error handling.
rpc = self._transport._wrapped_methods[self._transport.test_iam_permissions]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,16 @@
# limitations under the License.
#

from typing import Any, AsyncIterable, Awaitable, Callable, Iterable, Sequence, Tuple
from typing import (
Any,
AsyncIterable,
Awaitable,
Callable,
Iterable,
Sequence,
Tuple,
Optional,
)

from google.cloud.bigtable_admin_v2.types import bigtable_table_admin
from google.cloud.bigtable_admin_v2.types import table
Expand Down
24 changes: 10 additions & 14 deletions google/cloud/bigtable_v2/services/bigtable/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -621,12 +621,11 @@ def mutate_row(
request.table_name = table_name
if row_key is not None:
request.row_key = row_key
if mutations is not None:
request.mutations = mutations
if app_profile_id is not None:
request.app_profile_id = app_profile_id

if mutations:
request.mutations.extend(mutations)

# Wrap the RPC method; this adds retry and timeout information,
# and friendly error handling.
rpc = self._transport._wrapped_methods[self._transport.mutate_row]
Expand Down Expand Up @@ -730,12 +729,11 @@ def mutate_rows(

if table_name is not None:
request.table_name = table_name
if entries is not None:
request.entries = entries
if app_profile_id is not None:
request.app_profile_id = app_profile_id

if entries:
request.entries.extend(entries)

# Wrap the RPC method; this adds retry and timeout information,
# and friendly error handling.
rpc = self._transport._wrapped_methods[self._transport.mutate_rows]
Expand Down Expand Up @@ -881,14 +879,13 @@ def check_and_mutate_row(
request.row_key = row_key
if predicate_filter is not None:
request.predicate_filter = predicate_filter
if true_mutations is not None:
request.true_mutations = true_mutations
if false_mutations is not None:
request.false_mutations = false_mutations
if app_profile_id is not None:
request.app_profile_id = app_profile_id

if true_mutations:
request.true_mutations.extend(true_mutations)
if false_mutations:
request.false_mutations.extend(false_mutations)

# Wrap the RPC method; this adds retry and timeout information,
# and friendly error handling.
rpc = self._transport._wrapped_methods[self._transport.check_and_mutate_row]
Expand Down Expand Up @@ -1005,12 +1002,11 @@ def read_modify_write_row(
request.table_name = table_name
if row_key is not None:
request.row_key = row_key
if rules is not None:
request.rules = rules
if app_profile_id is not None:
request.app_profile_id = app_profile_id

if rules:
request.rules.extend(rules)

# Wrap the RPC method; this adds retry and timeout information,
# and friendly error handling.
rpc = self._transport._wrapped_methods[self._transport.read_modify_write_row]
Expand Down
2 changes: 1 addition & 1 deletion noxfile.py
Original file line number Diff line number Diff line change
Expand Up @@ -154,7 +154,7 @@ def cover(session):
test runs (not system test runs), and then erases coverage data.
"""
session.install("coverage", "pytest-cov")
session.run("coverage", "report", "--show-missing", "--fail-under=99")
session.run("coverage", "report", "--show-missing", "--fail-under=100")

session.run("coverage", "erase")

Expand Down
86 changes: 47 additions & 39 deletions synth.metadata
Original file line number Diff line number Diff line change
Expand Up @@ -4,15 +4,15 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/python-bigtable.git",
"sha": "6fe87016a159bbdc6bf29856b1cf6e633e16216a"
"sha": "76c4e9abd59ffac5fb2d8fb2298d04b9e1128d8c"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
"sha": "8d73f9486fc193a150f6c907dfb9f49431aff3ff",
"internalRef": "332497859"
"sha": "78f5365656fda2855cf0546080da559d6c2ed3ff",
"internalRef": "357293749"
}
},
{
Expand Down Expand Up @@ -51,7 +51,6 @@
}
],
"generatedFiles": [
".coveragerc",
".flake8",
".github/CONTRIBUTING.md",
".github/ISSUE_TEMPLATE/bug_report.md",
Expand Down Expand Up @@ -107,46 +106,51 @@
"docs/conf.py",
"docs/multiprocessing.rst",
"google/cloud/bigtable_admin_v2/__init__.py",
"google/cloud/bigtable_admin_v2/gapic/__init__.py",
"google/cloud/bigtable_admin_v2/gapic/bigtable_instance_admin_client.py",
"google/cloud/bigtable_admin_v2/gapic/bigtable_instance_admin_client_config.py",
"google/cloud/bigtable_admin_v2/gapic/bigtable_table_admin_client.py",
"google/cloud/bigtable_admin_v2/gapic/bigtable_table_admin_client_config.py",
"google/cloud/bigtable_admin_v2/gapic/enums.py",
"google/cloud/bigtable_admin_v2/gapic/transports/__init__.py",
"google/cloud/bigtable_admin_v2/gapic/transports/bigtable_instance_admin_grpc_transport.py",
"google/cloud/bigtable_admin_v2/gapic/transports/bigtable_table_admin_grpc_transport.py",
"google/cloud/bigtable_admin_v2/proto/__init__.py",
"google/cloud/bigtable_admin_v2/proto/bigtable_instance_admin.proto",
"google/cloud/bigtable_admin_v2/proto/bigtable_instance_admin_pb2.py",
"google/cloud/bigtable_admin_v2/proto/bigtable_instance_admin_pb2_grpc.py",
"google/cloud/bigtable_admin_v2/proto/bigtable_table_admin.proto",
"google/cloud/bigtable_admin_v2/proto/bigtable_table_admin_pb2.py",
"google/cloud/bigtable_admin_v2/proto/bigtable_table_admin_pb2_grpc.py",
"google/cloud/bigtable_admin_v2/proto/common.proto",
"google/cloud/bigtable_admin_v2/proto/common_pb2.py",
"google/cloud/bigtable_admin_v2/proto/common_pb2_grpc.py",
"google/cloud/bigtable_admin_v2/proto/instance.proto",
"google/cloud/bigtable_admin_v2/proto/instance_pb2.py",
"google/cloud/bigtable_admin_v2/proto/instance_pb2_grpc.py",
"google/cloud/bigtable_admin_v2/proto/table.proto",
"google/cloud/bigtable_admin_v2/proto/table_pb2.py",
"google/cloud/bigtable_admin_v2/proto/table_pb2_grpc.py",
"google/cloud/bigtable_admin_v2/types.py",
"google/cloud/bigtable_admin_v2/py.typed",
"google/cloud/bigtable_admin_v2/services/__init__.py",
"google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/__init__.py",
"google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/async_client.py",
"google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/client.py",
"google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/pagers.py",
"google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/transports/__init__.py",
"google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/transports/base.py",
"google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/transports/grpc.py",
"google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/transports/grpc_asyncio.py",
"google/cloud/bigtable_admin_v2/services/bigtable_table_admin/__init__.py",
"google/cloud/bigtable_admin_v2/services/bigtable_table_admin/async_client.py",
"google/cloud/bigtable_admin_v2/services/bigtable_table_admin/client.py",
"google/cloud/bigtable_admin_v2/services/bigtable_table_admin/pagers.py",
"google/cloud/bigtable_admin_v2/services/bigtable_table_admin/transports/__init__.py",
"google/cloud/bigtable_admin_v2/services/bigtable_table_admin/transports/base.py",
"google/cloud/bigtable_admin_v2/services/bigtable_table_admin/transports/grpc.py",
"google/cloud/bigtable_admin_v2/services/bigtable_table_admin/transports/grpc_asyncio.py",
"google/cloud/bigtable_admin_v2/types/__init__.py",
"google/cloud/bigtable_admin_v2/types/bigtable_instance_admin.py",
"google/cloud/bigtable_admin_v2/types/bigtable_table_admin.py",
"google/cloud/bigtable_admin_v2/types/common.py",
"google/cloud/bigtable_admin_v2/types/instance.py",
"google/cloud/bigtable_admin_v2/types/table.py",
"google/cloud/bigtable_v2/__init__.py",
"google/cloud/bigtable_v2/gapic/__init__.py",
"google/cloud/bigtable_v2/gapic/bigtable_client.py",
"google/cloud/bigtable_v2/gapic/bigtable_client_config.py",
"google/cloud/bigtable_v2/gapic/transports/__init__.py",
"google/cloud/bigtable_v2/gapic/transports/bigtable_grpc_transport.py",
"google/cloud/bigtable_v2/proto/__init__.py",
"google/cloud/bigtable_v2/proto/bigtable.proto",
"google/cloud/bigtable_v2/proto/bigtable_pb2.py",
"google/cloud/bigtable_v2/proto/bigtable_pb2_grpc.py",
"google/cloud/bigtable_v2/proto/data.proto",
"google/cloud/bigtable_v2/proto/data_pb2.py",
"google/cloud/bigtable_v2/proto/data_pb2_grpc.py",
"google/cloud/bigtable_v2/types.py",
"google/cloud/bigtable_v2/py.typed",
"google/cloud/bigtable_v2/services/__init__.py",
"google/cloud/bigtable_v2/services/bigtable/__init__.py",
"google/cloud/bigtable_v2/services/bigtable/async_client.py",
"google/cloud/bigtable_v2/services/bigtable/client.py",
"google/cloud/bigtable_v2/services/bigtable/transports/__init__.py",
"google/cloud/bigtable_v2/services/bigtable/transports/base.py",
"google/cloud/bigtable_v2/services/bigtable/transports/grpc.py",
"google/cloud/bigtable_v2/services/bigtable/transports/grpc_asyncio.py",
"google/cloud/bigtable_v2/types/__init__.py",
"google/cloud/bigtable_v2/types/bigtable.py",
"google/cloud/bigtable_v2/types/data.py",
"noxfile.py",
"renovate.json",
"samples/AUTHORING_GUIDE.md",
"samples/CONTRIBUTING.md",
Expand All @@ -160,6 +164,8 @@
"samples/snippets/README.md",
"samples/tableadmin/README.md",
"scripts/decrypt-secrets.sh",
"scripts/fixup_bigtable_admin_v2_keywords.py",
"scripts/fixup_bigtable_v2_keywords.py",
"scripts/readme-gen/readme_gen.py",
"scripts/readme-gen/templates/README.tmpl.rst",
"scripts/readme-gen/templates/auth.tmpl.rst",
Expand All @@ -168,8 +174,10 @@
"scripts/readme-gen/templates/install_portaudio.tmpl.rst",
"setup.cfg",
"testing/.gitignore",
"tests/unit/gapic/v2/test_bigtable_client_v2.py",
"tests/unit/gapic/v2/test_bigtable_instance_admin_client_v2.py",
"tests/unit/gapic/v2/test_bigtable_table_admin_client_v2.py"
"tests/unit/gapic/bigtable_admin_v2/__init__.py",
"tests/unit/gapic/bigtable_admin_v2/test_bigtable_instance_admin.py",
"tests/unit/gapic/bigtable_admin_v2/test_bigtable_table_admin.py",
"tests/unit/gapic/bigtable_v2/__init__.py",
"tests/unit/gapic/bigtable_v2/test_bigtable.py"
]
}