You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2026/05/10 01:11:01 UTC
(airflow) branch main updated: Combine noisy serde registration debug logs into one line (#66298)
This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 7a87418549c Combine noisy serde registration debug logs into one line (#66298)
7a87418549c is described below
commit 7a87418549c00131765cd4a651b87d26243b0413
Author: Jeongwoo Do <48...@users.noreply.github.com>
AuthorDate: Sun May 10 10:10:53 2026 +0900
Combine noisy serde registration debug logs into one line (#66298)
---
task-sdk/src/airflow/sdk/serde/__init__.py | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
diff --git a/task-sdk/src/airflow/sdk/serde/__init__.py b/task-sdk/src/airflow/sdk/serde/__init__.py
index a74d662fc99..d25da4b79b6 100644
--- a/task-sdk/src/airflow/sdk/serde/__init__.py
+++ b/task-sdk/src/airflow/sdk/serde/__init__.py
@@ -390,7 +390,6 @@ def _register():
raise AttributeError(
f"duplicate {s_qualname} for serialization in {module} and {_serializers[s_qualname]}"
)
- log.debug("registering %s for serialization", s_qualname)
_serializers[s_qualname] = module
for deserializers in getattr(module, "deserializers", ()):
d_qualname = deserializers if isinstance(deserializers, str) else qualname(deserializers)
@@ -398,7 +397,6 @@ def _register():
raise AttributeError(
f"duplicate {d_qualname} for deserialization in {module} and {_deserializers[d_qualname]}"
)
- log.debug("registering %s for deserialization", d_qualname)
_deserializers[d_qualname] = module
_extra_allowed.add(d_qualname)
for stringifiers in getattr(module, "stringifiers", ()):
@@ -407,10 +405,15 @@ def _register():
raise AttributeError(
f"duplicate {c_qualname} for stringifiers in {module} and {_stringifiers[c_qualname]}"
)
- log.debug("registering %s for stringifying", c_qualname)
_stringifiers[c_qualname] = module
- log.debug("loading serializers took %.3f ms", timer.duration)
+ log.debug(
+ "registered serializers=[%s] deserializers=[%s] stringifiers=[%s] in %.3f ms",
+ ", ".join(sorted(_serializers)),
+ ", ".join(sorted(_deserializers)),
+ ", ".join(sorted(_stringifiers)),
+ timer.duration,
+ )
@functools.cache