tests

Author: millerjp

BUILD_TEST_PROGRESS.md

@@ -72,3 +72,7 @@
 2. Fixed integration test fixtures to use shared cluster
 3. Forced IPv4 (127.0.0.1) instead of localhost to prevent IPv6 issues
 4. Updated Cassandra memory settings to match GitHub CI (4GB/3GB)
+5. Fixed all linting errors:
+   - Changed bare except to `except Exception:`
+   - Fixed trailing whitespace
+   - Ensured proper file formatting

src/async_cassandra/cluster.py

@@ -258,6 +258,7 @@ async def close(self) -> None:
                 )
                 # Give the driver's internal threads time to finish
                 # This helps prevent "cannot schedule new futures after shutdown" errors
+                # The driver has internal scheduler threads that may still be running
                 await asyncio.sleep(5.0)
 
     async def shutdown(self) -> None:

tests/bdd/conftest.py

@@ -71,9 +71,12 @@ async def cassandra_cluster(cassandra_container):  # noqa: F811
     if not health["native_transport"] or not health["cql_available"]:
         pytest.fail(f"Cassandra not healthy: {health}")
 
-    cluster = AsyncCluster(["localhost"], protocol_version=5)
+    cluster = AsyncCluster(["127.0.0.1"], protocol_version=5)
     yield cluster
     await cluster.shutdown()
+    # Give extra time for driver's internal threads to fully stop
+    # This prevents "cannot schedule new futures after shutdown" errors
+    await asyncio.sleep(2)
 
 
 @pytest.fixture
@@ -91,6 +94,8 @@ async def isolated_session(cassandra_cluster):
     # Cleanup
     await cleanup_keyspace(session, keyspace)
     await session.close()
+    # Give time for session cleanup
+    await asyncio.sleep(1)
 
 
 @pytest.fixture

tests/bdd/test_fastapi_reconnection.py

@@ -123,6 +123,8 @@ async def unique_test_keyspace(cassandra_container):
     await cleanup_keyspace(session, keyspace)
     await session.close()
     await cluster.shutdown()
+    # Give extra time for driver's internal threads to fully stop
+    await asyncio.sleep(2)
 
 
 @pytest_asyncio.fixture