Merge "Fix: On error continue processing workflows" into main

lfit · Feb 12, 2024 · ed81c7c · ed81c7c
2 parents 4124ca4 + 68e8ac0
commit ed81c7c
Showing 1 changed file with 20 additions and 14 deletions.
diff --git a/src/gerrit_to_platform/helpers.py b/src/gerrit_to_platform/helpers.py
@@ -127,13 +127,16 @@ def find_and_dispatch(project: str, workflow_filter: str, inputs: Dict[str, str]
                     + f"{inputs['GERRIT_CHANGE_NUMBER']} patch "
                     + inputs["GERRIT_PATCHSET_NUMBER"]
                 )
-                dispatcher(
-                    owner,
-                    repo,
-                    workflow["id"],
-                    f"refs/heads/{inputs['GERRIT_BRANCH']}",
-                    inputs,
-                )
+                try:
+                    dispatcher(
+                        owner,
+                        repo,
+                        workflow["id"],
+                        f"refs/heads/{inputs['GERRIT_BRANCH']}",
+                        inputs,
+                    )
+                except Exception as e:
+                    print(f"Failed to dispatch workflow: {e}")
 
             magic_repo = get_magic_repo(platform)
             if magic_repo:
@@ -152,13 +155,16 @@ def find_and_dispatch(project: str, workflow_filter: str, inputs: Dict[str, str]
                         + f"{inputs['GERRIT_PATCHSET_NUMBER']} against "
                         + f"{platform.value}:{owner}/{repo}"
                     )
-                    dispatcher(
-                        owner,
-                        magic_repo,
-                        workflow["id"],
-                        "refs/heads/main",
-                        inputs,
-                    )
+                    try:
+                        dispatcher(
+                            owner,
+                            magic_repo,
+                            workflow["id"],
+                            "refs/heads/main",
+                            inputs,
+                        )
+                    except Exception as e:
+                        print(f"Failed to dispatch workflow: {e}")
 
 
 def get_change_id(change: str) -> str: