support airflow dag restructure

pelotoncycle · Dec 4, 2023 · 835da58 · 835da58
1 parent 4eab26d
commit 835da58
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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: