nyoungstudios commented on PR #39772:
URL: https://github.com/apache/airflow/pull/39772#issuecomment-2599531232

   This pr isn't working since merging in the main branch from when the main 
branch was switched to Airflow 3.X.
   
   This is the current error I am receiving in the scheduler:
   
   ```
   --- Last chance exception handler ---
   Traceback (most recent call last):
     File 
"/path/to/airflow/task_sdk/src/airflow/sdk/execution_time/supervisor.py", line 
262, in _fork_main
       target()
     File "/path/to/airflow/airflow/dag_processing/processor.py", line 69, in 
_parse_file_entrypoint
       comms_decoder.send_request(log, result)
     File 
"/path/to/airflow/task_sdk/src/airflow/sdk/execution_time/task_runner.py", line 
382, in send_request
       encoded_msg = msg.model_dump_json().encode() + b"\n"
     File 
"/path/to/apache-airflow/lib/python3.10/site-packages/pydantic/main.py", line 
477, in model_dump_json
       return self.__pydantic_serializer__.to_json(
   pydantic_core._pydantic_core.PydanticSerializationError: Unable to serialize 
unknown type: <class 'airflow.models.xcom_arg.PlainXComArg'>
   ```
   
   And this is the error in the UI:
   (This example dag is the sample in the original pr description)
   ```
   Broken DAG: [/path/to/airflow/dags/example_dag.py] 
   Traceback (most recent call last):
     File "/path/to/airflow/airflow/serialization/serialized_objects.py", line 
1615, in serialize_dag
       serialized_dag["dag_dependencies"] = [x.__dict__ for x in 
sorted(dag_deps)]
     File "<string>", line 4, in __lt__
   TypeError: '<' not supported between instances of 'str' and 'PlainXComArg'
   
   During handling of the above exception, another exception occurred:
   
   Traceback (most recent call last):
     File "/path/to/airflow/airflow/serialization/serialized_objects.py", line 
1717, in to_dict
       json_dict = {"__version": cls.SERIALIZER_VERSION, "dag": 
cls.serialize_dag(var)}
     File "/path/to/airflow/airflow/serialization/serialized_objects.py", line 
1631, in serialize_dag
       raise SerializationError(f"Failed to serialize DAG {dag.dag_id!r}: {e}")
   airflow.exceptions.SerializationError: Failed to serialize DAG 
'trigger_dag': '<' not supported between instances of 'str' and 'PlainXComArg'
   ```
   
   I haven't been able to track down where this serialization problem is 
occurring yet, but if anyone has any suggestions - that would be appreciated!


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