Skip to content

Commit

Permalink
exclude files from being treated as folders in `table_definitions_fol…
Browse files Browse the repository at this point in the history
…der`
  • Loading branch information
charlielewisme committed Sep 2, 2024
1 parent 51f4f51 commit c168f8d
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions airflow/dags/polygon_parse_dag.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,8 @@
)

for folder in glob(table_definitions_folder):
if not os.path.isdir(folder):
continue
dataset = folder.split('/')[-1]

dag_id = f'polygon_parse_{dataset}_dag'
Expand Down

0 comments on commit c168f8d

Please sign in to comment.