don't fail when plane or koji are not responding

glehmann · glehmann · commit 56bbe014320a · 2025-04-15T11:47:45.000+02:00
Signed-off-by: Gaëtan Lehmann &lt;gaetan.lehmann@vates.tech&gt;
diff --git a/scripts/pkg_in_pipe/pkg_in_pipe.py b/scripts/pkg_in_pipe/pkg_in_pipe.py
@@ -1,8 +1,10 @@
 #!/usr/bin/env python
 
 import argparse
+import io
 import os
 from datetime import datetime
+import sys
 from textwrap import dedent
 
 import koji
@@ -22,6 +24,24 @@ def print_header(out):
         <body class="bg-gray-400 text-center">
         '''), file=out)
 
+def print_plane_warning(out):
+    print(dedent('''
+        <div class="px-3 py-3">
+        <div class="bg-orange-100 border-l-4 border-orange-500 text-orange-700 p-4" role="alert">
+            <p class="font-bold">Plane malfunction</p>
+            <p>The issues could not be retrieved from plane.</p>
+        </div>
+        </div>'''), file=out)
+
+def print_koji_error(out):
+    print(dedent('''
+        <div class="px-3 py-3">
+        <div class="bg-red-100 border border-red-400 text-red-700 px-4 py-3 rounded relative" role="alert">
+            <strong class="font-bold">Koji error!</strong>
+            <span class="block sm:inline">The report can't be generated.</span>
+        </div>
+        </div>'''), file=out)
+
 def print_footer(out, generated_info):
     now = datetime.now()
     print(dedent(f'''
@@ -93,26 +113,37 @@ def print_table_line(out, build, link, issues, by):
 parser.add_argument('--plane-token', help="The token used to access the plane api", default=os.environ['PLANE_TOKEN'])
 args = parser.parse_args()
 
-# open koji session
-config = koji.read_config("koji")
-session = koji.ClientSession('https://kojihub.xcp-ng.org', config)
-session.ssl_login(config['cert'], None, config['serverca'])
-
 # load the issues from plane, so we can search for the plane card related to a build
 resp = requests.get(
     'https://project.vates.tech/api/v1/workspaces/vates-global/projects/43438eec-1335-4fc2-8804-5a4c32f4932d/issues/',
     headers={'x-api-key': args.plane_token},
 )
-project_issues = resp.json()
+issues = resp.json().get('results', [])
 
+ok = True
 with open(args.output, 'w') as out:
     print_header(out)
+    if not issues:
+        print_plane_warning(out)
     tags = [f'v{v}-{p}' for v in ['8.2', '8.3'] for p in ['incoming', 'ci', 'testing', 'candidates', 'lab']]
-    for tag in tags:
-        print_table_header(out, tag)
-        for build in session.listTagged(tag):
-            build_url = f'https://koji.xcp-ng.org/buildinfo?buildID={build['build_id']}'
-            build_issues = [i for i in project_issues['results'] if f'href="{build_url}"' in i['description_html']]
-            print_table_line(out, build['nvr'], build_url, build_issues, build['owner_name'])
-        print_table_footer(out)
+    temp_out = io.StringIO()
+    try:
+        # open koji session
+        config = koji.read_config("koji")
+        session = koji.ClientSession('https://kojihub.xcp-ng.org', config)
+        session.ssl_login(config['cert'], None, config['serverca'])
+        for tag in tags:
+            print_table_header(temp_out, tag)
+            for build in session.listTagged(tag):
+                build_url = f'https://koji.xcp-ng.org/buildinfo?buildID={build['build_id']}'
+                build_issues = [i for i in issues if f'href="{build_url}"' in i['description_html']]
+                print_table_line(temp_out, build['nvr'], build_url, build_issues, build['owner_name'])
+            print_table_footer(temp_out)
+        out.write(temp_out.getvalue())
+    except Exception as e:
+        ok = False
+        print(f"error while building the report: {e}", file=sys.stderr)
+        print_koji_error(out)
     print_footer(out, args.generated_info)
+if not ok:
+    exit(1)
