antonlin1 opened a new pull request, #51932:
URL: https://github.com/apache/airflow/pull/51932

   Using `airflow 3.0.1` and `apache-airflow-providers-openlineage @ 
git+https://github.com/apache/airflow@398ba8672f18e43fa010fdd792f60fae19aa51b8#subdirectory=providers/openlineage`
 following error is thrown in openlineage provider:
   
   ```
   ERROR - Task failed with exception: source="task"
   AttributeError: 'RuntimeTaskInstance' object has no attribute 'dag_run'
   File 
"/usr/local/lib/python3.12/site-packages/airflow/sdk/execution_time/task_runner.py",
 line 838 in run
   
   File 
"/usr/local/lib/python3.12/site-packages/airflow/sdk/execution_time/task_runner.py",
 line 1130 in _execute_task
   
   File 
"/usr/local/lib/python3.12/site-packages/airflow/sdk/bases/operator.py", line 
408 in wrapper
   
   File 
"/opt/airflow/plugins/dd_airflow_operators/yoshi_spark/yoshi_spark_operator.py",
 line 97 in execute
   
   File 
"/opt/airflow/plugins/dd_airflow_operators/yoshi_spark/yoshi_spark_operator.py",
 line 124 in _create_spark_conf
   
   File 
"/usr/local/lib/python3.12/site-packages/airflow/providers/openlineage/utils/spark.py",
 line 175 in inject_parent_job_information_into_spark_properties
   
   File 
"/usr/local/lib/python3.12/site-packages/airflow/providers/openlineage/utils/spark.py",
 line 53 in _get_parent_job_information_as_spark_properties
   
   File 
"/usr/local/lib/python3.12/site-packages/airflow/providers/openlineage/plugins/macros.py",
 line 120 in lineage_root_run_id
   
   File "/usr/local/lib/python3.12/site-packages/pydantic/main.py", line 989 in 
__getattr__
   ```
   
   


-- 
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: commits-unsubscr...@airflow.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to