Skip to content

Commit d731597

Browse files
Passa para o próximo issue se levantar exceção (#392)
1 parent 652d6d1 commit d731597

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

airflow/dags/sync_isis_to_kernel.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -452,7 +452,13 @@ def mount_journals_issues_link(issues: List[dict]) -> dict:
452452
issues = filter_issues(issues)
453453

454454
for issue in issues:
455-
issue_to_link = issue_data_to_link(issue)
455+
try:
456+
issue_to_link = issue_data_to_link(issue)
457+
except TypeError as e:
458+
# pass para o próximo issue
459+
logging.error(f"Unable to link issue {e} {issue.data}")
460+
continue
461+
456462
issue_to_link["order"] = issue.data["issue"]["v36"][0]["_"]
457463
journal_id = issue.data.get("issue").get("v35")[0]["_"]
458464
journal_issues.setdefault(journal_id, [])

0 commit comments

Comments
 (0)