From 835da5823e3ff9014ff97e4c9981eb5455cc0f5e Mon Sep 17 00:00:00 2001
From: HaoWuPeloton <51166891+HaoWuPeloton@users.noreply.github.com>
Date: Sun, 3 Dec 2023 19:26:50 -0500
Subject: [PATCH] support airflow dag restructure

---
 dagfactory/dagfactory.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dagfactory/dagfactory.py b/dagfactory/dagfactory.py
index 4ba57838..9fb6070c 100644
--- a/dagfactory/dagfactory.py
+++ b/dagfactory/dagfactory.py
@@ -117,7 +117,7 @@ def from_directory(cls, config_dir, globals: Dict[str, Any], parent_default_conf
                         default_config['tags'] = sub_fpath.split("/")[5:7]
                 # catch the errors so the rest of the dags can still be imported
                 try:
-                    print("config_filepath="+config_filepath)
+                    print("config_filepath="+sub_fpath)
                     dag_factory = cls(config_filepath=sub_fpath, default_config=default_config)
                     dag_factory.generate_dags(globals)
                 except Exception as e: