ephraimbuddy opened a new pull request, #66107: URL: https://github.com/apache/airflow/pull/66107
The projected AIP-92 DB-to-API swap needs DagFileProcessorManager subclasses that route operations through the API server instead of the metadata DB. Two spots in the current implementation are awkward to override cleanly: - _run_parsing_loop calls DagWarning.purge_inactive_dag_warnings() directly, forcing subclasses to reimplement the parsing loop just to redirect or skip the cleanup. Promote it to an overridable instance method, purge_inactive_dag_warnings(), so subclasses can forward it to an API or no-op it without touching _run_parsing_loop. - Bundle refreshes triggered by external events (API callbacks, coordinator messages) had to mutate the private _force_refresh_bundles set directly. Expose request_bundle_refresh() as the public seam so event handlers can mark a bundle for refresh without reaching into private state. --- ##### Was generative AI tooling used to co-author this PR? - [x] Yes (please specify the tool below) Generated-by: Claude code (opus 4.7) -- 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]
