Skip to content

Commit

Permalink
feat: Enable RunQueryResponse.done (#572)
Browse files Browse the repository at this point in the history 
* chore: use gapic-generator-python 0.65.2

PiperOrigin-RevId: 444333013

Source-Link: googleapis/googleapis@f91b6cf

Source-Link: googleapis/googleapis-gen@16eb360
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMTZlYjM2MDk1YzI5NGU3MTJjNzRhMWJmMjM1NTA4MTdiNDIxNzRlNSJ9

* 🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

* feat:Enable RunQueryResponse.done

PiperOrigin-RevId: 444879243

Source-Link: googleapis/googleapis@c4b98bf

Source-Link: googleapis/googleapis-gen@497ddcd
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNDk3ZGRjZGVhZGNlZmYzNWIyODVjNmVhNDNmMzk5ZTcxZGMzMTNhZiJ9

* 🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
  • Loading branch information
@gcf-owl-bot
gcf-owl-bot[bot] and gcf-owl-bot[bot] committed Apr 28, 2022
1 parent 317ecc7 commit 3ec13da
Show file tree
Hide file tree
Showing 6 changed files with 238 additions and 195 deletions.
72 changes: 36 additions & 36 deletions google/cloud/firestore_admin_v1/services/firestore_admin/async_client.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -272,9 +272,9 @@ async def create_index(
from google.cloud import firestore_admin_v1
def sample_create_index():
async def sample_create_index():
# Create a client
client = firestore_admin_v1.FirestoreAdminClient()
client = firestore_admin_v1.FirestoreAdminAsyncClient()
# Initialize request argument(s)
request = firestore_admin_v1.CreateIndexRequest(
Expand All @@ -286,7 +286,7 @@ def sample_create_index():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down Expand Up @@ -390,9 +390,9 @@ async def list_indexes(
from google.cloud import firestore_admin_v1
def sample_list_indexes():
async def sample_list_indexes():
# Create a client
client = firestore_admin_v1.FirestoreAdminClient()
client = firestore_admin_v1.FirestoreAdminAsyncClient()
# Initialize request argument(s)
request = firestore_admin_v1.ListIndexesRequest(
Expand All @@ -403,7 +403,7 @@ def sample_list_indexes():
page_result = client.list_indexes(request=request)
# Handle the response
for response in page_result:
async for response in page_result:
print(response)
Args:
Expand Down Expand Up @@ -509,17 +509,17 @@ async def get_index(
from google.cloud import firestore_admin_v1
def sample_get_index():
async def sample_get_index():
# Create a client
client = firestore_admin_v1.FirestoreAdminClient()
client = firestore_admin_v1.FirestoreAdminAsyncClient()
# Initialize request argument(s)
request = firestore_admin_v1.GetIndexRequest(
name="name_value",
)
# Make the request
response = client.get_index(request=request)
response = await client.get_index(request=request)
# Handle the response
print(response)
Expand Down Expand Up @@ -616,17 +616,17 @@ async def delete_index(
from google.cloud import firestore_admin_v1
def sample_delete_index():
async def sample_delete_index():
# Create a client
client = firestore_admin_v1.FirestoreAdminClient()
client = firestore_admin_v1.FirestoreAdminAsyncClient()
# Initialize request argument(s)
request = firestore_admin_v1.DeleteIndexRequest(
name="name_value",
)
# Make the request
client.delete_index(request=request)
await client.delete_index(request=request)
Args:
request (Union[google.cloud.firestore_admin_v1.types.DeleteIndexRequest, dict]):
Expand Down Expand Up @@ -710,17 +710,17 @@ async def get_field(
from google.cloud import firestore_admin_v1
def sample_get_field():
async def sample_get_field():
# Create a client
client = firestore_admin_v1.FirestoreAdminClient()
client = firestore_admin_v1.FirestoreAdminAsyncClient()
# Initialize request argument(s)
request = firestore_admin_v1.GetFieldRequest(
name="name_value",
)
# Make the request
response = client.get_field(request=request)
response = await client.get_field(request=request)
# Handle the response
print(response)
Expand Down Expand Up @@ -834,9 +834,9 @@ async def update_field(
from google.cloud import firestore_admin_v1
def sample_update_field():
async def sample_update_field():
# Create a client
client = firestore_admin_v1.FirestoreAdminClient()
client = firestore_admin_v1.FirestoreAdminAsyncClient()
# Initialize request argument(s)
field = firestore_admin_v1.Field()
Expand All @@ -851,7 +851,7 @@ def sample_update_field():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down Expand Up @@ -959,9 +959,9 @@ async def list_fields(
from google.cloud import firestore_admin_v1
def sample_list_fields():
async def sample_list_fields():
# Create a client
client = firestore_admin_v1.FirestoreAdminClient()
client = firestore_admin_v1.FirestoreAdminAsyncClient()
# Initialize request argument(s)
request = firestore_admin_v1.ListFieldsRequest(
Expand All @@ -972,7 +972,7 @@ def sample_list_fields():
page_result = client.list_fields(request=request)
# Handle the response
for response in page_result:
async for response in page_result:
print(response)
Args:
Expand Down Expand Up @@ -1091,9 +1091,9 @@ async def export_documents(
from google.cloud import firestore_admin_v1
def sample_export_documents():
async def sample_export_documents():
# Create a client
client = firestore_admin_v1.FirestoreAdminClient()
client = firestore_admin_v1.FirestoreAdminAsyncClient()
# Initialize request argument(s)
request = firestore_admin_v1.ExportDocumentsRequest(
Expand All @@ -1105,7 +1105,7 @@ def sample_export_documents():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down Expand Up @@ -1209,9 +1209,9 @@ async def import_documents(
from google.cloud import firestore_admin_v1
def sample_import_documents():
async def sample_import_documents():
# Create a client
client = firestore_admin_v1.FirestoreAdminClient()
client = firestore_admin_v1.FirestoreAdminAsyncClient()
# Initialize request argument(s)
request = firestore_admin_v1.ImportDocumentsRequest(
Expand All @@ -1223,7 +1223,7 @@ def sample_import_documents():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down Expand Up @@ -1329,17 +1329,17 @@ async def get_database(
from google.cloud import firestore_admin_v1
def sample_get_database():
async def sample_get_database():
# Create a client
client = firestore_admin_v1.FirestoreAdminClient()
client = firestore_admin_v1.FirestoreAdminAsyncClient()
# Initialize request argument(s)
request = firestore_admin_v1.GetDatabaseRequest(
name="name_value",
)
# Make the request
response = client.get_database(request=request)
response = await client.get_database(request=request)
# Handle the response
print(response)
Expand Down Expand Up @@ -1426,17 +1426,17 @@ async def list_databases(
from google.cloud import firestore_admin_v1
def sample_list_databases():
async def sample_list_databases():
# Create a client
client = firestore_admin_v1.FirestoreAdminClient()
client = firestore_admin_v1.FirestoreAdminAsyncClient()
# Initialize request argument(s)
request = firestore_admin_v1.ListDatabasesRequest(
parent="parent_value",
)
# Make the request
response = client.list_databases(request=request)
response = await client.list_databases(request=request)
# Handle the response
print(response)
Expand Down Expand Up @@ -1520,9 +1520,9 @@ async def update_database(
from google.cloud import firestore_admin_v1
def sample_update_database():
async def sample_update_database():
# Create a client
client = firestore_admin_v1.FirestoreAdminClient()
client = firestore_admin_v1.FirestoreAdminAsyncClient()
# Initialize request argument(s)
request = firestore_admin_v1.UpdateDatabaseRequest(
Expand All @@ -1533,7 +1533,7 @@ def sample_update_database():
print("Waiting for operation to complete...")
response = operation.result()
response = await operation.result()
# Handle the response
print(response)
Expand Down
Loading

0 comments on commit 3ec13da

Please sign in to comment.