fixes

graphprotocol · Dec 4, 2024 · 51950cb · 51950cb
1 parent 233ff58
commit 51950cb
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/graph/src/blockchain/block_stream.rs b/graph/src/blockchain/block_stream.rs
@@ -343,7 +343,7 @@ impl<C: Blockchain> TriggersAdapterWrapper<C> {
             .get(&subgraph_filter.subgraph)
             .ok_or_else(|| anyhow!("Store not found for subgraph: {}", subgraph_filter.subgraph))?;
 
-        let schema = crate::components::store::ReadStore::input_schema(store);
+        let schema = <dyn crate::components::store::SourceableStore>::input_schema(store);
 
         let adapter = self.adapter.clone();
 
@@ -401,7 +401,7 @@ pub enum SubgraphTriggerScanRange<C: Blockchain> {
 
 async fn scan_subgraph_triggers<C: Blockchain>(
     logger: &Logger,
-    store: &Arc<dyn WritableStore>,
+    store: &Arc<dyn SourceableStore>,
     adapter: &Arc<dyn TriggersAdapter<C>>,
     schema: &InputSchema,
     filter: &SubgraphFilter,
@@ -435,7 +435,7 @@ pub struct EntityWithType {
 }
 
 async fn get_entities_for_range(
-    store: &Arc<dyn WritableStore>,
+    store: &Arc<dyn SourceableStore>,
     filter: &SubgraphFilter,
     schema: &InputSchema,
     from: BlockNumber,