adjust the db creation text
@@ -20,12 +20,16 @@ if not skip:
def setup_athena_db(my_session, db_name="splink_awswrangler_test"):
"""
+ =====
+ Partially deprecated by the new garbage_collection function.
+ =====
+
Run this function if you need to create, or recreate the database(s)
used in this test.
"""
# If our database already exists, delete and recreate it,
- # so we ensure we have no cached datasets to read from.
+ # so we ensure we have no cached data to read from.
if db_name in wr.catalog.databases(limit=10000).values:
wr.catalog.delete_database(name=db_name, boto3_session=my_session)
# clean up folder contents from s3...
@@ -72,7 +76,7 @@ def create_and_upload_test_data(my_session):
return db_name_read, db_name_write
-@pytest.mark.skip(reason="AWS Connection Required")
+# @pytest.mark.skip(reason="AWS Connection Required")
def test_full_example_athena(tmp_path):
"""
@@ -127,7 +131,7 @@ def test_full_example_athena(tmp_path):
linker.unlinkables_chart(source_dataset="Testing")
-@pytest.mark.skip(reason="AWS Connection Required")
+# @pytest.mark.skip(reason="AWS Connection Required")
def test_athena_garbage_collection():
# creates a session at least on the platform...
@@ -162,7 +166,7 @@ def test_athena_garbage_collection():
assert len(files) == 0
-@pytest.mark.skip(reason="AWS Connection Required")
+# @pytest.mark.skip(reason="AWS Connection Required")
def test_athena_df_as_input():
import pandas as pd
@@ -187,7 +191,7 @@ def test_athena_df_as_input():
linker.predict()
-@pytest.mark.skip(reason="AWS Connection Required")
+# @pytest.mark.skip(reason="AWS Connection Required")
def test_athena_link_only():
import pandas as pd
