bolkedebruin commented on PR #28333: URL: https://github.com/apache/airflow/pull/28333#issuecomment-1354462615
@hugochinchilla the scheduler won't starve in that case if the `dataset_triggered_dag_ids` is filtered before the query with `max_dagruns_to_create_per_loop` runs. This is the case already so there, so that does not require extra work. depending the approach this line: https://github.com/apache/airflow/blob/2794662459b6d2f40b55b9b1d39eed14b5c3c5e9/airflow/models/dag.py#L3349 changed to support SQLAlchemy filtering or python filtering. I currently do not think that an extra field in the database is warranted, also not for the simple implementation. What also is sticking out is that a change to the serialization format is being made. I think this should be versioned as it is backwards incompatible. -- 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]
