Merge pull request #20 from wey-gu/more_coverage

adding coverage of ut further more

Author: wey-gu

.coveragerc

@@ -0,0 +1,11 @@
+[run]
+source = py_pglite
+
+[report]
+# Exclude files that are not meant to be tested directly
+# We indeed cannot pytest pytest fixtures
+# because they are not meant to be tested directly.
+omit =
+    py_pglite/fixtures.py
+    py_pglite/django/fixtures.py
+    py_pglite/sqlalchemy/fixtures.py

py_pglite/__init__.py

@@ -4,7 +4,7 @@
 and Python test suites with support for SQLAlchemy, SQLModel, and Django.
 """
 
-__version__ = "0.4.1"
+__version__ = "0.5.0"
 
 # Core exports (always available)
 # Database client exports (choose your preferred client)

py_pglite/clients.py

@@ -130,9 +130,32 @@ def execute_query(
         """Execute query using asyncpg (sync wrapper)."""
         loop = self._get_event_loop()
         try:
-            return loop.run_until_complete(
-                self._async_execute_query(connection, query, params)
-            )
+            # Check if we can use run_until_complete
+            if loop.is_running():
+                # If the loop is already running, we need to handle this differently
+                # This can happen in testing environments like pytest
+                import warnings
+
+                warnings.warn(
+                    "AsyncpgClient used in running event loop context. "
+                    "Consider using PsycopgClient for synchronous operations.",
+                    RuntimeWarning,
+                    stacklevel=2,
+                )
+                # For now, we'll try to execute synchronously by creating a new loop
+                # in a thread, but this is not ideal
+                import concurrent.futures
+
+                with concurrent.futures.ThreadPoolExecutor() as executor:
+                    future = executor.submit(
+                        self._asyncio.run,
+                        self._async_execute_query(connection, query, params),
+                    )
+                    return future.result()
+            else:
+                return loop.run_until_complete(
+                    self._async_execute_query(connection, query, params)
+                )
         except Exception as e:
             # Ensure we don't leave any coroutines hanging
             logger.warning(f"AsyncpgClient execute_query failed: {e}")

py_pglite/django/backend/base.py

@@ -235,6 +235,8 @@ def __init__(self, settings_dict: dict[str, Any], alias: str = "default"):
         # Ensure we use the PGlite creation class
         settings_dict = settings_dict.copy()
 
+        # Set up parent class
+        self.settings_dict = settings_dict
         super().__init__(settings_dict, alias)  # type: ignore
         self.creation = PGliteDatabaseCreation(self)  # type: ignore
 
@@ -266,6 +268,7 @@ def get_new_connection(self, conn_params: dict[str, Any]) -> Any:
                             }
                         )
 
+        # Call parent class's method using super()
         return super().get_new_connection(conn_params)  # type: ignore
 
     def get_database_version(self):