test consolidation

Author: millerjp

tests/integration/test_concurrent_operations.py

@@ -255,54 +255,3 @@ async def insert_and_read(i):
         # With single node, both should succeed equally
         assert one_success == 100
         assert all_success == 100
-
-    @pytest.mark.asyncio
-    async def test_prepared_statement_concurrency(self, cassandra_session: AsyncCassandraSession):
-        """Test that prepared statements work correctly through the async wrapper."""
-        # Create a table for testing prepared statements
-        await cassandra_session.execute("DROP TABLE IF EXISTS prepared_test")
-        await cassandra_session.execute(
-            """
-            CREATE TABLE prepared_test (
-                id INT PRIMARY KEY,
-                name TEXT,
-                value INT
-            )
-            """
-        )
-
-        # Prepare statements
-        insert_stmt = await cassandra_session.prepare(
-            "INSERT INTO prepared_test (id, name, value) VALUES (?, ?, ?)"
-        )
-        select_stmt = await cassandra_session.prepare("SELECT * FROM prepared_test WHERE id = ?")
-
-        # Test concurrent usage of prepared statements
-        async def insert_and_select(test_id):
-            # Insert using prepared statement
-            await cassandra_session.execute(insert_stmt, [test_id, f"test_{test_id}", test_id * 10])
-
-            # Select using prepared statement
-            result = await cassandra_session.execute(select_stmt, [test_id])
-            row = result.one()
-            return row
-
-        # Run a modest number of concurrent operations to verify functionality
-        tasks = [insert_and_select(i) for i in range(10)]
-        results = await asyncio.gather(*tasks)
-
-        # Verify results
-        for i, row in enumerate(results):
-            assert row.id == i
-            assert row.name == f"test_{i}"
-            assert row.value == i * 10
-
-        # Verify we can reuse prepared statements
-        await cassandra_session.execute(insert_stmt, [100, "reused", 1000])
-        result = await cassandra_session.execute(select_stmt, [100])
-        row = result.one()
-        assert row.id == 100
-        assert row.name == "reused"
-        assert row.value == 1000
-
-        print("\nPrepared statements work correctly through async wrapper")