-
Notifications
You must be signed in to change notification settings - Fork 14.2k
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
Airflow assume task context is serialized with Pydantic models #42485
Comments
Currently context is not supported in trigger's, if you need any values from the context object , extract and send as key-->values. |
Yeah. We might want to handle it better - so better error message should be printed in this case. Marked it as good-first-issue. |
This issue has been automatically marked as stale because it has been open for 14 days with no response from the author. It will be closed in next 7 days if no further activity occurs from the issue author. |
Apache Airflow version
Other Airflow 2 version (please specify below)
If "Other Airflow 2 version" selected, which one?
2.10.2
What happened?
The triggerer terminates when attempting to deserialize the task context dictionary.
The issue started appearing when I upgraded from Airflow 2.9.3 to Airflow 2.10.2.
Do note that I have a custom trigger where I am serializing the task context.
What you think should happen instead?
I believe the deserialize operation should not be forcing
use_pydantic_models
to be true.Instead, it should be using the value passed as a parameter.
Also, when the task context is being serialized, it is respecting the value passed to the serialized function.
How to reproduce
Operating System
n/a
Versions of Apache Airflow Providers
No response
Deployment
Astronomer
Deployment details
No response
Anything else?
No response
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: