JASNOTJAZZ commented on issue #47348: URL: https://github.com/apache/airflow/issues/47348#issuecomment-2700935879
Check the Serialization Logic: The error is occurring in the XCom.serialize_value method, which is trying to serialize the user-defined macros using JSON. The XComEncoder is raising an error because it encounters a reserved key (__classname__) in the dictionary. You need to ensure that the user-defined macros do not contain any reserved keys or special characters that might interfere with the serialization process. Modify the User-Defined Macros: Instead of directly passing the result of the macro functions (user_macro1(225) and user_macro2(100)), pass the functions themselves and call them within the task. This way, the serialization will handle the functions rather than their results, which might contain problematic keys. Update the DAG Definition: Modify the DAG definition to pass the macro functions themselves rather than their results. Then, call these functions within the task. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
