This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 99a77a77f4 Humanise log output about retrieved DAG(s) (#35338)
99a77a77f4 is described below
commit 99a77a77f4612b9a332a206059e2fbb4cb691bad
Author: Andrey Anshin <[email protected]>
AuthorDate: Fri Nov 3 01:16:02 2023 +0400
Humanise log output about retrieved DAG(s) (#35338)
---
airflow/dag_processing/processor.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/dag_processing/processor.py
b/airflow/dag_processing/processor.py
index cb873daf61..5242dad956 100644
--- a/airflow/dag_processing/processor.py
+++ b/airflow/dag_processing/processor.py
@@ -830,7 +830,7 @@ class DagFileProcessor(LoggingMixin):
return 0, 0
if dagbag.dags:
- self.log.info("DAG(s) %s retrieved from %s", dagbag.dags.keys(),
file_path)
+ self.log.info("DAG(s) %s retrieved from %s", ", ".join(map(repr,
dagbag.dags)), file_path)
else:
self.log.warning("No viable dags retrieved from %s", file_path)
DagFileProcessor.update_import_errors(
