Is there a recommended way to add polars.DataFrame
to _serializers
and _deserializers
?
#40413
Unanswered
phi-friday
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I found that the
pandas.DataFrame
returned byTask
can be serialized correctly because_serializers
has added a serialization function to thepandas.DataFrame
object.And
_serializers
is lazily loading a canonicalized form of the submodule inairflow.serialization.serializers
.To make
polars.DataFrame
serializable, I can do the followingxcom backend
)_serializers
However, I don't think it's a good idea to do the above just to add a serialization function.
Is there a way to add a serialization function, or add a serialization submodule in
airflow.serialization.serializers
?Beta Was this translation helpful? Give feedback.
All reactions