Prepare backfill: catch exception in clients and send message (#307)

Will only merge this after we have all deployed the new server code
cashapp · May 23, 2023 · 32973f0 · 32973f0
1 parent 2d1a24f
commit 32973f0
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/client-base/src/main/kotlin/app/cash/backfila/client/spi/BackfilaClientServiceHandler.kt b/client-base/src/main/kotlin/app/cash/backfila/client/spi/BackfilaClientServiceHandler.kt
@@ -31,7 +31,13 @@ class BackfilaClientServiceHandler @Inject constructor(
       logger.info { "Preparing backfill `${request.backfill_name}`" }
 
       val operator = operatorFactory.create(request.backfill_name)
-      return@withBackfillRunLogging operator.prepareBackfill(request)
+      try {
+        return@withBackfillRunLogging operator.prepareBackfill(request)
+      } catch (exception: Exception) {
+        return@withBackfillRunLogging PrepareBackfillResponse.Builder()
+          .error_message(exception.message)
+          .build()
+      }
     }
   }