Asquator commented on issue #49508: URL: https://github.com/apache/airflow/issues/49508#issuecomment-2887162602
> [@Asquator](https://github.com/Asquator) What’s your thought on how windowing can be implemented here? I implemented a minimal query that considers _Backfills_ and _DAGruns_ to find the greatest number of each DAG that can be scheduled: https://github.com/apache/airflow/pull/50692 I'm not sure if the windowing logic belongs to `DagRun`, it's more of a scheduler's responsibility. On the whole I really liked the solution @uranusjr proposed, at least for _DAGruns_ where there's no strict priority ordering - just update `last_scheduling_decision` every time the model is touched. Looks like it's original intention was for _TaskInstances_, but I don't see if it's ever updated after initialization. It can be also extended to _TaskInstances_ if we're able to change the behavior of priority weights. Also, I think the parallel discussion about starving _TaskInstances_ should be reopened since these are two different bugs, and the fixes may be different. -- 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: commits-unsubscr...@airflow.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
