Close capture and db resources

Author: tobiasraabe

src/pytask_parallel/execute.py

@@ -256,10 +256,27 @@ def pytask_execute_task(session: Session, task: PTask) -> Future[WrapperResult]:
 
 
 @hookimpl
-def pytask_unconfigure() -> None:
-    """Clean up the parallel executor."""
+def pytask_unconfigure(session: Session) -> None:
+    """Clean up the parallel executor and release per-session resources."""
+    # Ensure global state is reset between runs.
     registry.reset()
 
+    # The installed pytask version does not yet release capture/database resources
+    # on unconfigure, so do it here to avoid leaking file descriptors across runs.
+    from _pytask import database_utils  # noqa: PLC0415
+    from _pytask.capture import CaptureManager  # noqa: PLC0415
+
+    capman = session.config["pm"].get_plugin("capturemanager")
+    if isinstance(capman, CaptureManager):
+        capman.stop_capturing()
+
+    engine = getattr(database_utils, "_ENGINE", None)
+    if engine is None:
+        engine = getattr(database_utils.DatabaseSession, "kw", {}).get("bind")
+    if engine is not None:
+        engine.dispose()
+        database_utils.DatabaseSession.configure(bind=None)
+
 
 def _update_carry_over_products(
     task: PTask, carry_over_products: PyTree[CarryOverPath | PythonNode | None] | None