jason810496 commented on code in PR #65958:
URL: https://github.com/apache/airflow/pull/65958#discussion_r3158935390
##########
airflow-core/src/airflow/dag_processing/manager.py:
##########
@@ -812,14 +815,31 @@ def _find_files_in_bundle(self, bundle: BaseDagBundle) ->
list[Path]:
return rel_paths
+ def _get_runtime_file_extensions(self) -> tuple[str, ...]:
+ """Collect file extensions from registered runtime coordinators
(cached after first call)."""
+ if self._runtime_file_extensions is not None:
+ return self._runtime_file_extensions
+
+ from airflow.providers_manager import ProvidersManager
+
+ extensions: list[str] = []
+ for coordinator_cls in ProvidersManager().coordinators:
Review Comment:
The answer is similar to
https://github.com/apache/airflow/pull/65956#discussion_r3158510441 comment.
Only if the dag-processor install the target `sdk.<lang>` provider will
enable the dag-parsing for pure-<lang>-dag.
--
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]
