gbonazzoli opened a new issue, #51610:
URL: https://github.com/apache/airflow/issues/51610

   ### Apache Airflow version
   
   3.0.2
   
   ### If "Other Airflow 2 version" selected, which one?
   
   _No response_
   
   ### What happened?
   
   I Have a Task with the following code that runs well on Airflow 2.x since 
ever:
   
   ```python
   def execute_Retrieve_Sophos_Rule_XML(**kwargs):
       ti = kwargs['ti']
       queue_name = ti.queue
       .....
   ```
   
   On airflow 3.0.2 I got the following error:
   
   ```
   [2025-06-11, 10:06:57] ERROR - Task failed with exception: source="task"
   AttributeError: 'RuntimeTaskInstance' object has no attribute 'queue'
   
[2025-0[6](https://airflow-tre.colombinigroup.com/dags/SOPHOS_PORT_KNOCKING/runs/manual__2025-06-11T08:06:55.647081+00:00/tasks/Retrieve_Sophos_Rule_XML?try_number=1#6)-11,
 10:06:57] ERROR - Top level error: source="task"
   UndefinedError: 'airflow.sdk.execution_time.task_runner.RuntimeTaskInstance 
object' has no attribute 'log_url'
   File 
"/root/venv/lib/python3.12/site-packages/airflow/sdk/execution_time/task_runner.py",
 line 1297 in main
   
   File 
"/root/venv/lib/python3.12/site-packages/airflow/sdk/execution_time/task_runner.py",
 line 1277 in finalize
   
   File 
"/root/venv/lib/python3.12/site-packages/airflow/sdk/execution_time/task_runner.py",
 line 1105 in _send_task_error_email
   
   File 
"/root/venv/lib/python3.12/site-packages/airflow/models/taskinstance.py", line 
411 in _get_email_subject_content
   
   File 
"/root/venv/lib/python3.12/site-packages/airflow/models/taskinstance.py", line 
408 in render
   
   File "/root/venv/lib/python3.12/site-packages/airflow/utils/helpers.py", 
line 244 in render_template_to_string
   
   File "/root/venv/lib/python3.12/site-packages/airflow/utils/helpers.py", 
line 239 in render_template
   
   File "<template>", line 22 in root
   
   File "/root/venv/lib/python3.12/site-packages/jinja2/runtime.py", line 859 
in _fail_with_undefined_error
   
   [2025-06-11, 10:06:58] WARNING - Process exited abnormally: exit_code=1: 
source="task"
   ```
   
   
   ### What you think should happen instead?
   
   Execute in the "default" queue if it is not defined on the Task's DAG 
specification.
   
   ### How to reproduce
   
   Create a DAG with a task and query the "queue" attrivbute.
   
   ### Operating System
   
   Ubuntu 24.04
   
   ### Versions of Apache Airflow Providers
   
   Does not care
   
   ### Deployment
   
   Virtualenv installation
   
   ### Deployment details
   
   In a LXD container
   
   ### Anything else?
   
   no
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [x] I agree to follow this project's [Code of 
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


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