Support datetime.time and timedelta as task input and output

... or anywhere where JSON serialization is needed.

Author: windiana42

docs/source/changelog.md

@@ -1,6 +1,9 @@
 # Changelog
 
-## 0.12.1 (2025-10-DD)
+## 0.12.2 (2025-10-DD)
+- Support datetime.time and timedelta as task input and output (or anywhere where JSON serialization is needed).
+
+## 0.12.1 (2025-10-10)
 - Create all metadata tables even if some metadata tables already exist.
   This fixes problems with conditional need for sync_views table.
 - Make table hooks work even without ConfigContext (see example_mssql/download_parquet_files.py)

src/pydiverse/pipedag/util/json.py

@@ -44,6 +44,8 @@ class Type(str, Enum):
     PATHLIB_PATH = "pathlib:path"
     DT_DATE = "dt:date"
     DT_DATETIME = "dt:datetime"
+    DT_TIME = "dt:time"
+    DT_TIMEDELTA = "dt:timedelta"
 
     def __str__(self):
         return self.value
@@ -142,6 +144,19 @@ def json_default(o):
             TYPE_KEY: Type.DT_DATE,
             "date": o.isoformat(),
         }
+    if isinstance(o, dt.time):
+        return {
+            TYPE_KEY: Type.DT_TIME,
+            "time": o.isoformat(),
+        }
+    if isinstance(o, dt.timedelta):
+        return {
+            TYPE_KEY: Type.DT_TIMEDELTA,
+            "days": o.days,
+            "seconds": o.seconds,
+            "microseconds": o.microseconds,
+            # docstring of timedelta says: Representation: (days, seconds, microseconds).
+        }
     if get_origin(o) is not None:
         # must be GenericAlias
         # somehow isinstance(o, GenericAlias) did not work reliably
@@ -270,6 +285,10 @@ def get_stage(name: str | None):
         return Path(d["path"])
     if type_ == Type.DT_DATE:
         return dt.date.fromisoformat(d["date"])
+    if type_ == Type.DT_TIME:
+        return dt.time.fromisoformat(d["time"])
+    if type_ == Type.DT_TIMEDELTA:
+        return dt.timedelta(d["days"], d["seconds"], d["microseconds"])
     if type_ == Type.DT_DATETIME:
         return dt.datetime.fromisoformat(d["datetime"])
     if type_ == Type.DATA_CLASS: