vikramkoka commented on PR #67930:
URL: https://github.com/apache/airflow/pull/67930#issuecomment-4608413581

   > > This got fixed in #67924 :) since a new provider release is about to 
happen
   > 
   > Not sure actually. I just tested it a few minutes ago and the analysis DAG 
failed
   
   The test output was:
   
    [2026-06-02 18:37:51] ERROR - Exception rendering Jinja template for task 
'build_retrieval_kwargs', field 'op_args'. Template:                
     (XComArg(<Task(_PythonDecoratedOperator): extract_sub_questions>),)        
                                                                   
     ImportError: 
unusual_prefix_d2861fea3245e1f5af3daeb0a37685aac392179a_example_langchain_10k.SubQuestion
 was not found in allow list for        
     deserialization imports. To allow it, add it to 
allowed_deserialization_classes in the configuration                            
              
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/definitions/_internal/templater.py", 
line 189 in _do_render_template_fields                       
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/definitions/_internal/templater.py", 
line 269 in render_template                                  
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/definitions/_internal/templater.py", 
line 269 in <genexpr>                                        
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/definitions/_internal/templater.py", 
line 265 in render_template                                  
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/definitions/xcom_arg.py", line 
359 in resolve                                                     
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/execution_time/task_runner.py", line 512 
in xcom_pull                                             
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/bases/xcom.py", line 265 in 
get_one                                                               
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/bases/xcom.py", line 348 in 
deserialize_value                                                     
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/serde/__init__.py", line 302 
in deserialize                                                       
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/serde/__init__.py", line 302 
in <listcomp>                                                        
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/serde/__init__.py", line 344 
in deserialize                                                       
                                                                                
                                                                   
     [2026-06-02 18:37:51] ERROR - Task failed with exception                   
                                                                   
     ImportError: 
unusual_prefix_d2861fea3245e1f5af3daeb0a37685aac392179a_example_langchain_10k.SubQuestion
 was not found in allow list for        
     deserialization imports. To allow it, add it to 
allowed_deserialization_classes in the configuration                            
              
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/execution_time/task_runner.py", line 
1430 in run                                                  
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/execution_time/task_runner.py", line 186 
in wrapper                                               
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/execution_time/task_runner.py", line 
1287 in _prepare                                             
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/execution_time/task_runner.py", line 186 
in wrapper                                               
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/execution_time/task_runner.py", line 409 
in render_templates                                      
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/bases/operator.py", line 1635 
in render_template_fields                                           
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/definitions/_internal/templater.py", 
line 189 in _do_render_template_fields                       
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/definitions/_internal/templater.py", 
line 269 in render_template                                  
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/definitions/_internal/templater.py", 
line 269 in <genexpr>                                        
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/definitions/_internal/templater.py", 
line 265 in render_template                                  
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/definitions/xcom_arg.py", line 
359 in resolve                                                     
                                                                                
                                                                   
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/execution_time/task_runner.py", line 512 
in xcom_pull                                             
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/bases/xcom.py", line 265 in 
get_one                                                               
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/bases/xcom.py", line 348 in 
deserialize_value                                                     
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/serde/__init__.py", line 302 
in deserialize                                                       
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/serde/__init__.py", line 302 
in <listcomp>                                                        
                                                                                
                                                                   
     File "/opt/airflow/task-sdk/src/airflow/sdk/serde/__init__.py", line 344 
in deserialize                                                       
   
   ⏺ The Pydantic-native approach hits a second problem: SubQuestion objects 
get serialized to XCom, but the downstream task can't deserialize them
      because the class (defined in the DAG file) isn't in Airflow's 
allowed_deserialization_classes.
   
   


-- 
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]

Reply via email to