indexer: don't store pending cursor

Author: fracek

CHANGELOG.rst

@@ -1,6 +1,15 @@
 Changelog
 =========
 
+Apibara Python SDK 0.7.1 (UNRELEASED)
+--------------------------------------
+
+Fixed
+^^^^^
+
+ - Don't store pending cursor to avoid crashing on restart.
+
+
 Apibara Python SDK 0.7.0 (2023-07-08)
 --------------------------------------
 

src/apibara/indexer/runner.py

@@ -205,9 +205,20 @@ async def _connect_and_stream(self, indexer: Indexer, ctx: Optional[UserContext]
 
                 logger.debug(f"handle batch {cursor} - {end_cursor}")
 
-                with self._indexer_storage.create_storage_for_data(
-                    message.data.end_cursor
-                ) as storage:
+                if is_pending:
+                    create_storage = (
+                        lambda cursor: self._indexer_storage.create_storage_for_pending(
+                            cursor
+                        )
+                    )
+                else:
+                    create_storage = (
+                        lambda cursor: self._indexer_storage.create_storage_for_data(
+                            cursor
+                        )
+                    )
+
+                with create_storage(message.data.end_cursor) as storage:
                     additional_filter = None
                     for batch in message.data.data:
                         decoded_data = indexer.decode_data(batch)