Merge branch 'googleapis:main' into main

Author: ankitaluthra1

packages/google-cloud-documentai-toolbox/setup.py

@@ -68,7 +68,7 @@
         "intervaltree>=3.0.0",
         "pikepdf>=8.0.0, <11.0.0",
         "immutabledict>=2.0.0, <5.0.0",
-        "Pillow>=10.0.0, <12.0.0",
+        "Pillow>=10.0.0, <13.0.0",
         "Jinja2>=3.1.0, <4.0.0",
     ),
     python_requires=">=3.10",

packages/google-cloud-logging/google/cloud/logging_v2/handlers/structured_log.py

@@ -77,7 +77,7 @@ def __init__(
         Args:
             labels (Optional[dict]): Additional labels to attach to logs.
             stream (Optional[IO]): Stream to be used by the handler.
-            project (Optional[str]): Project Id associated with the logs.
+            project_id (Optional[str]): Project Id associated with the logs.
             json_encoder_cls (Optional[Type[JSONEncoder]]): Custom JSON encoder. Defaults to json.JSONEncoder
         """
         super(StructuredLogHandler, self).__init__(stream=stream)

packages/google-cloud-spanner/samples/samples/async_snippets.py

@@ -26,7 +26,7 @@ async def async_create_client(instance_id, database_id):
     """Instantiates an asynchronous Spanner client."""
     spanner_client = AsyncClient()
     instance = spanner_client.instance(instance_id)
-    database = instance.database(database_id)
+    database = await instance.database(database_id)
 
     print("Async Spanner client instantiated successfully.")
     return database
@@ -40,7 +40,7 @@ async def async_query_data(instance_id, database_id):
     """Queries sample data from the database using asynchronous SQL."""
     spanner_client = AsyncClient()
     instance = spanner_client.instance(instance_id)
-    database = instance.database(database_id)
+    database = await instance.database(database_id)
 
     async with database.snapshot() as snapshot:
         results = await snapshot.execute_sql(
@@ -59,7 +59,7 @@ async def async_insert_data(instance_id, database_id):
     """Inserts sample data into the database using DML asynchronously."""
     spanner_client = AsyncClient()
     instance = spanner_client.instance(instance_id)
-    database = instance.database(database_id)
+    database = await instance.database(database_id)
 
     async def insert_singers(transaction):
         dml = (
@@ -81,7 +81,7 @@ async def async_read_write_transaction(instance_id, database_id):
     """Performs an asynchronous read-write transaction."""
     spanner_client = AsyncClient()
     instance = spanner_client.instance(instance_id)
-    database = instance.database(database_id)
+    database = await instance.database(database_id)
 
     async def update_singer_lastname(transaction):
         # Retrieve current name
@@ -110,7 +110,7 @@ async def async_read_only_transaction(instance_id, database_id):
     """Performs an asynchronous read-only transaction."""
     spanner_client = AsyncClient()
     instance = spanner_client.instance(instance_id)
-    database = instance.database(database_id)
+    database = await instance.database(database_id)
 
     async with database.snapshot() as snapshot:
         # Execute a read using standard KeySet