fix: Catch error in flag poller for local evaluation (#13)

amplitude · Oct 10, 2023 · 5084ed2 · 5084ed2
1 parent b28edf4
commit 5084ed2
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/src/main/kotlin/flag/FlagConfigService.kt b/src/main/kotlin/flag/FlagConfigService.kt
@@ -44,13 +44,19 @@ internal class FlagConfigServiceImpl(
 
     override fun start() {
         lock.once {
-            refresh()
             poller.scheduleAtFixedRate(
-                { refresh() },
+                {
+                    try {
+                        refresh()
+                    } catch (e: Exception) {
+                        Logger.e("Failed to refresh flag configs.", e)
+                    }
+                },
                 config.flagConfigPollerIntervalMillis,
                 config.flagConfigPollerIntervalMillis,
                 TimeUnit.MILLISECONDS
             )
+            refresh()
         }
     }