From b21eded5e587615054f030641a276e30cc9f5f29 Mon Sep 17 00:00:00 2001
From: Jonas Finnemann Jensen <jonasfj@google.com>
Date: Wed, 4 Sep 2024 11:12:57 +0200
Subject: [PATCH] more  try / catch

---
 app/lib/task/backend.dart | 20 +++++++++++++++++---
 1 file changed, 17 insertions(+), 3 deletions(-)

diff --git a/app/lib/task/backend.dart b/app/lib/task/backend.dart
index 3c20ba8ab..694c59761 100644
--- a/app/lib/task/backend.dart
+++ b/app/lib/task/backend.dart
@@ -121,9 +121,21 @@ class TaskBackend {
         while (!aborted.isCompleted) {
           // Acquire the global lock and scan for package changes while lock is
           // valid.
-          await lock.withClaim((claim) async {
-            await _scanForPackageUpdates(claim, abort: aborted);
-          }, abort: aborted);
+          try {
+            await lock.withClaim((claim) async {
+              await _scanForPackageUpdates(claim, abort: aborted);
+            }, abort: aborted);
+          } catch (e, st) {
+            // Log this as very bad, and then move on. Nothing good can come
+            // from straight up stopping.
+            _log.shout(
+              'scanning failed (will retry when lock becomes free)',
+              e,
+              st,
+            );
+            // Sleep 5 minutes to reduce risk of degenerate behavior
+            await Future.delayed(Duration(minutes: 5));
+          }
         }
       } catch (e, st) {
         _log.severe('scanning loop crashed', e, st);
@@ -159,6 +171,8 @@ class TaskBackend {
               e,
               st,
             );
+            // Sleep 5 minutes to reduce risk of degenerate behavior
+            await Future.delayed(Duration(minutes: 5));
           }
         }
       } catch (e, st) {