Skip to content

Commit 7931de5

Browse files
committed
fix for parse retry document committee sessions
1 parent bd79196 commit 7931de5

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

airflow/knesset_data_pipelines/committees/parsed_document_committee_sessions.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@ def parse_retry_error(type_, error, document_session_id, group_type_id, applicat
4141
for filepath in [download_filepath, parsed_filepath, hash_filepath]:
4242
if os.path.exists(filepath):
4343
os.remove(filepath)
44+
os.makedirs(os.path.dirname(retry_filepath), exist_ok=True)
4445
with open(retry_filepath, 'w') as f:
4546
f.write(str(retry_num))
4647

0 commit comments

Comments
 (0)