Skip to content

Commit

Permalink
support airflow dag restructure
Browse files Browse the repository at this point in the history
  • Loading branch information
HaoWuPeloton committed Dec 5, 2023
1 parent f50ca5d commit 3f733bc
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion dagfactory/dagfactory.py
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ def from_directory(cls, config_dir, globals: Dict[str, Any], parent_default_conf
default_config['default_args']['owner'] = sub_fpath.split("/")[4]
default_config['tags'] = sub_fpath.split("/")[5:7]
else:
logger.info(f"Ingored invalid dag config file: {sub_fpath} ")
logger.info(f"Ignored invalid dag config file: {sub_fpath} ")
continue
# catch the errors so the rest of the dags can still be imported
try:
Expand Down

0 comments on commit 3f733bc

Please sign in to comment.