Fix database test concurrency issue

Author: hoijnet

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "terminusdb-client"
-version = "12.0.3"
+version = "12.0.5"
 description = "Python client for Terminus DB"
 authors = ["TerminusDB group"]
 license = "Apache Software License"

terminusdb_client/tests/integration_tests/conftest.py

@@ -145,9 +145,7 @@ def docker_url(pytestconfig):
     """
     # Check if a server is already running (port 6363)
     if is_local_server_running():
-        print(
-            "\n✓ Using existing TerminusDB server at http://127.0.0.1:6363"
-        )
+        print("\n✓ Using existing TerminusDB server at http://127.0.0.1:6363")
         yield "http://127.0.0.1:6363"
         return  # Don't clean up - server was already running
 

terminusdb_client/tests/integration_tests/test_client.py

@@ -12,6 +12,65 @@
 
 test_user_agent = "terminusdb-client-python-tests"
 
+_CLIENT_TEST_DBS = ["test_diff_ops"]
+_CLIENT_TEST_ORGS = ["testOrg235091"]
+
+
+@pytest.fixture(scope="module", autouse=True)
+def cleanup_client_resources(docker_url):
+    """Delete stale databases and organizations before the module and clean up after."""
+    client = Client(docker_url, user_agent=test_user_agent)
+    client.connect()
+
+    def _cleanup():
+        for db in _CLIENT_TEST_DBS:
+            try:
+                client.delete_database(db)
+            except Exception:
+                pass
+        for org in _CLIENT_TEST_ORGS:
+            # Ensure admin has access so we can list and delete databases
+            try:
+                client.change_capabilities(
+                    {
+                        "operation": "grant",
+                        "scope": f"Organization/{org}",
+                        "user": "User/admin",
+                        "roles": ["Role/admin"],
+                    }
+                )
+            except Exception:
+                pass
+            try:
+                dbs = client.get_organization_user_databases(org=org, username="admin")
+                for db in dbs:
+                    try:
+                        client.delete_database(db["name"], team=org)
+                    except Exception:
+                        pass
+            except Exception:
+                pass
+            # Revoke capabilities before deleting org
+            try:
+                client.change_capabilities(
+                    {
+                        "operation": "revoke",
+                        "scope": f"Organization/{org}",
+                        "user": "User/admin",
+                        "roles": ["Role/admin"],
+                    }
+                )
+            except Exception:
+                pass
+            try:
+                client.delete_organization(org)
+            except Exception:
+                pass
+
+    _cleanup()
+    yield
+    _cleanup()
+
 
 def test_not_ok():
     client = Client("http://localhost:6363")

terminusdb_client/tests/integration_tests/test_schema.py

@@ -8,6 +8,33 @@
 
 test_user_agent = "terminusdb-client-python-tests"
 
+_SCHEMA_TEST_DBS = [
+    "test_docapi",
+    "test_docapi2",
+    "test_datetime",
+    "test_compress_data",
+    "test_repeated_load",
+    "test_repeated_load_fails",
+]
+
+
+@pytest.fixture(scope="module", autouse=True)
+def cleanup_schema_databases(docker_url):
+    """Delete stale databases before the module and clean up after."""
+    client = Client(docker_url, user_agent=test_user_agent)
+    client.connect()
+    for db in _SCHEMA_TEST_DBS:
+        try:
+            client.delete_database(db)
+        except Exception:
+            pass
+    yield
+    for db in _SCHEMA_TEST_DBS:
+        try:
+            client.delete_database(db)
+        except Exception:
+            pass
+
 
 def test_create_schema(docker_url, test_schema):
     my_schema = test_schema