jscheffl commented on code in PR #65958:
URL: https://github.com/apache/airflow/pull/65958#discussion_r3156842433
##########
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:
Would we assume that (if multiple) all Dag Parsers load the language
interpreters? I could well imagine I spin one (or multiple) Dag parser for
Python and one additional for Java - then would deploy the JAR and JDK only to
the instances where needed... and on the Python Dag parser would add the
GitSyncBundle... (which on the Java side probably is not used).
Not sure if everybody likes to deploy a JDK into each Dag parser environment
--
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]
