uranusjr commented on code in PR #66107:
URL: https://github.com/apache/airflow/pull/66107#discussion_r3166860723
##########
airflow-core/src/airflow/dag_processing/manager.py:
##########
@@ -534,6 +534,16 @@ def claim_priority_files(self) -> list[DagFileInfo]:
"""
return self._claim_priority_files()
+ def request_bundle_refresh(self, bundle_name: str) -> None:
+ """
+ Request that ``bundle_name`` be refreshed on the next refresh tick.
+
+ Use this from event handlers reacting to external signals to mark a
+ bundle as needing refresh; the next call to
:meth:`_refresh_dag_bundles`
+ will not skip it via :meth:`should_skip_refresh`.
+ """
+ self._force_refresh_bundles.add(bundle_name)
Review Comment:
Looks like this not currently used anywhere?
Since the only existing usage to `_force_refresh_bundles` is in
`_queue_requested_files_for_parsing`, and it actually bulk-adds multiple names
at one time, should this function handle multiple names instead?
```python
def request_bundle_refresh(self, bundle_names: Iterable[str]) -> None:
```
--
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]
