Avoid TransactionNow instances ending up in logging.

Author: Majsvaffla

src/dreng/logging.py

@@ -1,13 +1,20 @@
 import logging
 from logging import INFO, WARNING
 
+from django.contrib.postgres.functions import TransactionNow
+
 __all__ = ["INFO", "WARNING", "getLogger"]
 
 
 class JobArgsFilter(logging.Filter):
     def filter(self, record: logging.LogRecord) -> logging.LogRecord:
-        if (job := getattr(record, "job", {})) and isinstance(job, dict) and "args" in job:
-            job["args"] = str(job["args"])[:1000]  # Avoid "overflowing" logging infrastructure.
+        if (job := getattr(record, "job", {})) and isinstance(job, dict):
+            if args := job.get("args"):
+                job["args"] = str(args)[:1000]  # Avoid "overflowing" logging infrastructure.
+            if (created_at := job.get("created_at")) and isinstance(created_at, TransactionNow):
+                job["created_at"] = None  # Avoid 'TransactionNow()' ending up in logging infrastructure.
+            if (execute_at := job.get("execute_at")) and isinstance(execute_at, TransactionNow):
+                job["execute_at"] = None  # Avoid 'TransactionNow()' ending up in logging infrastructure.
         return record
 
 

tests/logging.py

@@ -1,8 +1,10 @@
 from typing import Any
 
 import pytest
+from django.contrib.postgres.functions import TransactionNow
 
 from dreng import logging
+from tests.helpers import datetime_utc
 
 
 @pytest.mark.parametrize(
@@ -16,6 +18,26 @@
             {"slack": {"chill": True}},
             {},
         ),
+        (
+            {
+                "slack": {"chill": True},
+                "job": {
+                    "created_at": datetime_utc(2025, 12, 25, 13, 37),
+                    "execute_at": datetime_utc(2025, 12, 24, 14, 47),
+                },
+            },
+            {"created_at": datetime_utc(2025, 12, 25, 13, 37), "execute_at": datetime_utc(2025, 12, 24, 14, 47)},
+        ),
+        (
+            {
+                "slack": {"chill": True},
+                "job": {
+                    "created_at": TransactionNow(),
+                    "execute_at": TransactionNow(),
+                },
+            },
+            {"created_at": None, "execute_at": None},
+        ),
     ],
 )
 def test_JobArgsFilter(caplog: pytest.LogCaptureFixture, extra: dict[str, Any], expected_job: dict[str, Any]) -> None: