ferruzzi commented on code in PR #62984:
URL: https://github.com/apache/airflow/pull/62984#discussion_r2928103742
##########
providers/amazon/src/airflow/providers/amazon/aws/executors/batch/batch_executor.py:
##########
@@ -127,26 +128,40 @@ def __init__(self, *args, **kwargs):
def queue_workload(self, workload: workloads.All, session: Session | None)
-> None:
Review Comment:
@onikolas is likely thinking of `SchedulerWorkload` from
workloads/types.py, but @dondaum may be right, that isn't going to be in 2.11
so we can't use that until we bunmp the min_ver.
I think we could do a conditional import though:
```python
workload_type_hint = workloads.All
if airflow version > 3.2:
from airflow.executors.workloads.types import SchedulerWorkload
workload_type_hint = SchedulerWorkload
```
And that will force it to get cleaned up later when we pin the versions up??
--
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]
