[BERTE-565] Fix keyerror when workflow dispatch is triggered on the c…

…ommit_status checked

CHANGELOG

@@ -1,6 +1,10 @@
 # Change Log
 All notable changes to this project will be documented in this file.
 
+## [3.6.9] - 2022-04-25
+# Fixed
+- Fix Key error when workflow dispatch is triggered on the commit_status checked
+
 ## [3.6.9] - 2022-04-25
 # Fixed
 - Handle GitHub Actions status when workflow is pending.

bert_e/git_host/github/__init__.py

@@ -570,7 +570,7 @@ def _get_check_suite_ids(self, workflow_runs):
             map(lambda elem: elem['check_suite_id'], workflow_runs)
         )
 
-    def _get_aggregate_workflow_dispatched(self):
+    def _get_aggregate_workflow_dispatched(self, page):
         ref = self._check_suites[0]['head_sha']
         repo = self._check_suites[0]['repository']['name']
         owner = self._check_suites[0]['repository']['owner']['login']
@@ -580,7 +580,8 @@ def _get_aggregate_workflow_dispatched(self):
             owner=owner, repo=repo, ref=ref,
             params={
                 'event': 'workflow_dispatch',
-                'branch': self._check_suites[0]['head_branch']
+                'branch': self._check_suites[0]['head_branch'],
+                'page': page
             })
 
     def remove_unwanted_workflows(self):
@@ -592,10 +593,13 @@ def remove_unwanted_workflows(self):
         if self._check_suites.__len__() == 0:
             return
 
-        response = self._get_aggregate_workflow_dispatched()
+        page = 1
+        response = self._get_aggregate_workflow_dispatched(page)
         dispatched = self._get_check_suite_ids(response.workflow_runs)
+
         while len(dispatched) < response.total_count:
-            response = self._get_aggregate_workflow_dispatched()
+            page += 1
+            response = self._get_aggregate_workflow_dispatched(page)
             dispatched += self._get_check_suite_ids(response.workflow_runs)
 
         self._check_suites = list(filter(

bert_e/git_host/github/schema.py

@@ -114,6 +114,7 @@ class WorkflowRun(Schema):
     head_sha = fields.Str()
     head_branch = fields.Str()
     status = fields.Str()
+    check_suite_id = fields.Integer()
 
 
 class AggregateWorkflowRuns(Schema):