You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
Repository navigation
Airflow >= 2.2.0 execution date change is failing TaskInstance get_task_instances method and possibly others #21656
This is my first time reporting or posting on this forum. Please let me know if I need to provide any more information. Thanks for looking at this!
I have a Python Operator that uses the BaseOperator get_task_instances method and during the execution of this method, I encounter the following error:
This error is from doing an upgrade from airflow 1.10.15 -> 2.2.3.
I am using SQLAlchemy version 1.2.24 but I also tried with version 1.2.23 and encountered the same error. However, I do not think this is a sqlAlchemy issue.
The issue seems to have been introduced with Airflow 2.2.0 (pr: https://github.com/apache/airflow/pull/17719/files), where the TaskInstance.execution_date changed from being a column to this association_proxy. I do not have deep knowledge of SQLAlchemny so I am not sure why this change was made, but it results in it the error I'm getting.
2.2 .0 +
1.10.15
if you follow the stack trace you will get to this chunk of code that leads to the error because the association_proxy has a 'clause_element' attr, but the attr raises the exception in the error when called.
What you expected to happen
No response
How to reproduce
No response
Operating System
Linux from the official airflow helm chart docker image python version 3.7
The only extra dependency I am using is awscli==1.20.65. I have changed very little with the deployment besides a few environments variables and some pod annotations.
changed the title [-]Airflow >= 2.1.0 execution date change is failing TaskInstance get_task_instances method and possibly others[/-][+]Airflow >= 2.2.0 execution date change is failing TaskInstance get_task_instances method and possibly others[/+]on Feb 17, 2022
Activity
boring-cyborg commentedon Feb 17, 2022
Thanks for opening your first issue here! Be sure to follow the issue template!
[-]Airflow >= 2.1.0 execution date change is failing TaskInstance get_task_instances method and possibly others[/-][+]Airflow >= 2.2.0 execution date change is failing TaskInstance get_task_instances method and possibly others[/+]