ashb commented on code in PR #56039:
URL: https://github.com/apache/airflow/pull/56039#discussion_r2377186380
##########
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:
@uranusjr Is that `Operator` type still accurate, or is there a base class
that both MappedOperator and normal Operator in the scheduler both inherit from?
@kacpermuda No nothing functionally wrong with keeping it on DagRun, just if
we're extracting it now might be the time to put it in a place that "makes
sense" rather than is just slightly better than it was.
--
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]
