-
Notifications
You must be signed in to change notification settings - Fork 14.8k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Serialize pod_override to JSON before pickling executor_config #24356
Serialize pod_override to JSON before pickling executor_config #24356
Conversation
8a6a0a5
to
3a2dbeb
Compare
Not sure if this impacts things: but executor config can be used for other executors too |
Yeah I tried to be mindful of that. I don't just serialize the whole executor config. I only serialize the |
3a2dbeb
to
9f1a16c
Compare
e21c922
to
769efd9
Compare
The PR most likely needs to run full matrix of tests because it modifies parts of the core of Airflow. However, committers might decide to merge it quickly and take the risk. If they don't merge it quickly - please rebase it to the latest main at your convenience, or amend the last commit of the PR, and push it with --force-with-lease. |
If we unpickle a k8s object that was pickled under an earlier k8s library version, then the unpickled object may throw an error when to_dict is called. To be more tolerant of version changes we convert to JSON using Airflow's serializer before pickling.
258a90a
to
6255d97
Compare
Random failure. Merging. |
* Serialize pod_override to JSON before pickling executor_config If we unpickle a k8s object that was pickled under an earlier k8s library version, then the unpickled object may throw an error when to_dict is called. To be more tolerant of version changes we convert to JSON using Airflow's serializer before pickling. (cherry picked from commit c1d621c)
If we unpickle a k8s object that was pickled under an earlier k8s library version, then the unpickled object may throw an error when to_dict is called. To be more tolerant of version changes we convert to JSON using Airflow's serializer before pickling.