uranusjr commented on code in PR #56039:
URL: https://github.com/apache/airflow/pull/56039#discussion_r2447724553
##########
airflow-core/src/airflow/models/dagrun.py:
##########
@@ -1977,6 +1977,36 @@ def get_latest_runs(cls, session: Session = NEW_SESSION)
-> list[DagRun]:
)
).all()
+ @staticmethod
+ def is_schedulable_task(task: Operator) -> bool:
Review Comment:
ti.task can be MappedOperator (we don’t expand in the scheduler), but I
think you can just put this on TaskInstance instead?
More fundamentally though, this is in the scheduler, and the OL logic is run
in the worker, so you won’t be able to access this logic in the OL provider no
matter where you put it. I think this change is a lost cause unless we move the
OL integration into the scheduler.
--
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]
