chore: use more verbose paths in hello snippets (#1045)

Author: daniel-sanche

samples/beam/requirements-test.txt

@@ -1 +1 @@
-pytest==8.3.2
+pytest

samples/hello/async_main.py

@@ -31,11 +31,11 @@
 # [START bigtable_async_hw_imports]
 from google.cloud import bigtable
 from google.cloud.bigtable.data import row_filters
-from google.cloud.bigtable.data import RowMutationEntry
-from google.cloud.bigtable.data import SetCell
-from google.cloud.bigtable.data import ReadRowsQuery
 # [END bigtable_async_hw_imports]
 
+# use to ignore warnings
+row_filters
+
 
 async def main(project_id, instance_id, table_id):
     # [START bigtable_async_hw_connect]
@@ -85,8 +85,8 @@ async def main(project_id, instance_id, table_id):
             #
             #     https://cloud.google.com/bigtable/docs/schema-design
             row_key = "greeting{}".format(i).encode()
-            row_mutation = RowMutationEntry(
-                row_key, SetCell(column_family_id, column, value)
+            row_mutation = bigtable.data.RowMutationEntry(
+                row_key, bigtable.data.SetCell(column_family_id, column, value)
             )
             mutations.append(row_mutation)
         await table.bulk_mutate_rows(mutations)
@@ -95,7 +95,7 @@ async def main(project_id, instance_id, table_id):
         # [START bigtable_async_hw_create_filter]
         # Create a filter to only retrieve the most recent version of the cell
         # for each column across entire row.
-        row_filter = row_filters.CellsColumnLimitFilter(1)
+        row_filter = bigtable.data.row_filters.CellsColumnLimitFilter(1)
         # [END bigtable_async_hw_create_filter]
 
         # [START bigtable_async_hw_get_with_filter]
@@ -112,7 +112,7 @@ async def main(project_id, instance_id, table_id):
         # [START bigtable_async_hw_scan_with_filter]
         # [START bigtable_async_hw_scan_all]
         print("Scanning for all greetings:")
-        query = ReadRowsQuery(row_filter=row_filter)
+        query = bigtable.data.ReadRowsQuery(row_filter=row_filter)
         async for row in await table.read_rows_stream(query):
             cell = row.cells[0]
             print(cell.value.decode("utf-8"))

samples/hello/main.py

@@ -36,6 +36,10 @@
 
 # [END bigtable_hw_imports]
 
+# use to avoid warnings
+row_filters
+column_family
+
 
 def main(project_id, instance_id, table_id):
     # [START bigtable_hw_connect]
@@ -52,7 +56,7 @@ def main(project_id, instance_id, table_id):
     print("Creating column family cf1 with Max Version GC rule...")
     # Create a column family with GC policy : most recent N versions
     # Define the GC policy to retain only the most recent 2 versions
-    max_versions_rule = column_family.MaxVersionsGCRule(2)
+    max_versions_rule = bigtable.column_family.MaxVersionsGCRule(2)
     column_family_id = "cf1"
     column_families = {column_family_id: max_versions_rule}
     if not table.exists():
@@ -93,7 +97,7 @@ def main(project_id, instance_id, table_id):
         # [START bigtable_hw_create_filter]
         # Create a filter to only retrieve the most recent version of the cell
         # for each column across entire row.
-        row_filter = row_filters.CellsColumnLimitFilter(1)
+        row_filter = bigtable.row_filters.CellsColumnLimitFilter(1)
         # [END bigtable_hw_create_filter]
 
         # [START bigtable_hw_get_with_filter]

samples/hello/requirements-test.txt

@@ -1 +1 @@
-pytest==8.3.2
+pytest

samples/hello_happybase/requirements-test.txt

@@ -1 +1 @@
-pytest==8.3.2
+pytest

samples/instanceadmin/requirements-test.txt

@@ -1 +1 @@
-pytest==8.3.2
+pytest

samples/metricscaler/requirements-test.txt

@@ -1,3 +1,3 @@
-pytest==8.3.2
+pytest
 mock==5.1.0
 google-cloud-testutils

samples/quickstart/requirements-test.txt

@@ -1,2 +1,2 @@
-pytest==8.3.2
+pytest
 pytest-asyncio

samples/quickstart_happybase/requirements-test.txt

@@ -1 +1 @@
-pytest==8.3.2
+pytest

samples/snippets/data_client/requirements-test.txt

@@ -1,2 +1,2 @@
-pytest==8.3.2
+pytest
 pytest-asyncio

samples/snippets/deletes/deletes_async_test.py

@@ -30,6 +30,14 @@
 TABLE_ID = f"mobile-time-series-deletes-async-{str(uuid.uuid4())[:16]}"
 
 
+@pytest.fixture(scope="module")
+def event_loop():
+    import asyncio
+    loop = asyncio.get_event_loop_policy().new_event_loop()
+    yield loop
+    loop.close()
+
+
 @pytest_asyncio.fixture(scope="module", autouse=True)
 async def table_id() -> AsyncGenerator[str, None]:
     with create_table_cm(PROJECT, BIGTABLE_INSTANCE, TABLE_ID, {"stats_summary": None, "cell_plan": None}, verbose=False):

samples/snippets/deletes/requirements-test.txt

@@ -1,2 +1,2 @@
-pytest==8.3.2
+pytest
 pytest-asyncio

samples/snippets/filters/filter_snippets_async_test.py

@@ -34,6 +34,14 @@
 TABLE_ID = f"mobile-time-series-filters-async-{str(uuid.uuid4())[:16]}"
 
 
+@pytest.fixture(scope="module")
+def event_loop():
+    import asyncio
+    loop = asyncio.get_event_loop_policy().new_event_loop()
+    yield loop
+    loop.close()
+
+
 @pytest_asyncio.fixture(scope="module", autouse=True)
 async def table_id() -> AsyncGenerator[str, None]:
     with create_table_cm(PROJECT, BIGTABLE_INSTANCE, TABLE_ID, {"stats_summary": None, "cell_plan": None}):

samples/snippets/filters/requirements-test.txt

@@ -1,2 +1,2 @@
-pytest==8.3.2
+pytest
 pytest-asyncio

samples/snippets/reads/requirements-test.txt

@@ -1 +1 @@
-pytest==8.3.2
+pytest

samples/snippets/writes/requirements-test.txt

@@ -1,2 +1,2 @@
 backoff==2.2.1
-pytest==8.3.2
+pytest

samples/tableadmin/requirements-test.txt

@@ -1,2 +1,2 @@
-pytest==8.3.2
+pytest
 google-cloud-testutils==1.4.0