fix: catch filenotfound exception when rollover before upload (#103)

amplitude · Feb 3, 2023 · 80bc1f5 · 80bc1f5
1 parent 5547dac
commit 80bc1f5
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/core/src/main/java/com/amplitude/core/platform/EventPipeline.kt b/core/src/main/java/com/amplitude/core/platform/EventPipeline.kt
@@ -11,7 +11,6 @@ import kotlinx.coroutines.isActive
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.withContext
 import java.io.FileNotFoundException
-import java.lang.Exception
 import java.util.concurrent.atomic.AtomicInteger
 
 class EventPipeline(
@@ -99,7 +98,13 @@ class EventPipeline(
         uploadChannel.consumeEach {
 
             withContext(amplitude.storageIODispatcher) {
-                storage.rollover()
+                try {
+                    storage.rollover()
+                } catch (e: FileNotFoundException) {
+                    e.message?.let {
+                        amplitude.logger.warn("Event storage file not found: $it")
+                    }
+                }
             }
 
             val eventsData = storage.readEventsContent()