Release ready

Author: lsbardel

docs/release-notes.md

@@ -1,5 +1,28 @@
 # Release Notes
 
+## v2.4.0
+
+Lazy settings via pydantic-settings, JSONB params filtering for task
+history, and customisable route prefixes.
+
+- Settings are now lazy — resolved on first access instead of at import
+  time. Env vars use a `FLUID_` prefix by default; legacy unprefixed names
+  are kept as aliases.
+  ([#100](https://github.com/quantmind/aio-fluid/pull/100))
+- The task database plugin accepts a `route_prefix` parameter for
+  customising history route URLs and replaces `with_task_history_router()`
+  with a `register_routes()` method.
+  ([#100](https://github.com/quantmind/aio-fluid/pull/100))
+- Task history queries support filtering by run params via a new `params`
+  field (renamed from `HistoryQuery` to `TaskHistoryQuery`).
+  ([#99](https://github.com/quantmind/aio-fluid/pull/99))
+- **Database migration required:** the `params` column is now `JSONB` with
+  a GIN index. See the example
+  [migration](https://github.com/quantmind/aio-fluid/blob/main/examples/tasks/migrations/versions/d941c11ca25a_jsonb.py)
+  for the schema changes.
+- Removed `get_logger` from `fluid.utils.log`. Task loggers are now obtained
+  directly via `logging.getLogger(module)`.
+
 ## v2.3.1
 
 **v2.3.0 is broken — do not use it.**

examples/full_cli.py

@@ -20,6 +20,7 @@ def create_cli() -> TaskManagerCLI:
     # create the client
     task_manager_cli = TaskManagerCLI(
         task_app(plugins=[TaskDbPlugin(db)]),
+        log_config=dict(app_names=["fluid", "examples"]),
         commands=list(DEFAULT_COMMANDS)
         + [DbGroup(db, help="Task database plugin management")],
         help="Task Manager CLI with db plugin",

fluid/scheduler/models.py

@@ -26,7 +26,7 @@
 from typing_extensions import Annotated, Doc, TypedDict
 
 from fluid import settings
-from fluid.utils import kernel, log
+from fluid.utils import kernel
 from fluid.utils.data import compact_dict
 from fluid.utils.dates import as_utc, utcnow
 from fluid.utils.text import create_uid, trim_docstring
@@ -797,9 +797,10 @@ def create_task(
             kwargs.update(defaults)
         kwargs.update(compact_dict(self.kwargs))
         name = kwargs["name"]
+        module = kwargs.get("module") or settings.APP_NAME
         kwargs.update(
             executor=executor,
-            logger=log.get_logger(f"task.{name}", prefix=True),
+            logger=logging.getLogger(f"{module}.{name}"),
         )
         return Task(**kwargs)
 

fluid/utils/log.py

@@ -12,24 +12,13 @@
 from fluid import settings
 
 
-def get_logger(name: str = "", prefix: bool = False) -> logging.Logger:
-    # Only resolve the application base logger (and therefore the settings) on
-    # the paths that actually need it, so that the common module-level
-    # ``get_logger(__name__)`` call does not populate the settings cache at
-    # import time.
-    if not prefix and name:
-        return logging.getLogger(name)
-    base = logging.getLogger(settings.APP_NAME)
-    return base.getChild(name) if name else base
-
-
 def get_level_num(level: str | int) -> int:
     if isinstance(level, int):
         return level
     return getattr(logging, level.upper())
 
 
-def log_config(
+def _log_config(
     level: str | int | None = None,
     other_level: str | int = logging.WARNING,
     app_names: Sequence[str] | None = None,
@@ -136,7 +125,7 @@ def config(
     ] = None,
 ) -> dict:
     """Configure logging for the application"""
-    cfg = log_config(
+    cfg = _log_config(
         level=level,
         other_level=other_level,
         app_names=app_names,

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "aio-fluid"
-version = "2.3.1"
+version = "2.4.0"
 description = "Tools for backend python services"
 authors = [
     { name = "Luca Sbardella", email = "luca@quantmind.com" },