From 7e3f622aebe7f2e968de42637b66d79b6965882e Mon Sep 17 00:00:00 2001 From: Joffrey Bienvenu Date: Fri, 9 Feb 2024 05:48:13 +0100 Subject: [PATCH] fix: put custom serializer block after builtin serializers --- airflow/serialization/serde.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/airflow/serialization/serde.py b/airflow/serialization/serde.py index 2c880317b4a83d..8f07762c0a9c7f 100644 --- a/airflow/serialization/serde.py +++ b/airflow/serialization/serde.py @@ -141,18 +141,18 @@ def serialize(o: object, depth: int = 0) -> U | None: qn = "builtins.tuple" classname = qn - # custom serializers - dct = { - CLASSNAME: qn, - VERSION: getattr(cls, "__version__", DEFAULT_VERSION), - } - # if there is a builtin serializer available use that if qn in _serializers: data, serialized_classname, version, is_serialized = _serializers[qn].serialize(o) if is_serialized: return encode(classname or serialized_classname, version, serialize(data, depth + 1)) + # custom serializers + dct = { + CLASSNAME: qn, + VERSION: getattr(cls, "__version__", DEFAULT_VERSION), + } + # object / class brings their own if hasattr(o, "serialize"): data = getattr(o, "serialize")()