Skip to content

Commit 1f66779

Browse files
author
Zoran Cvetkov
committed
fixes
1 parent b52622b commit 1f66779

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

graph/src/blockchain/block_stream.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -343,7 +343,7 @@ impl<C: Blockchain> TriggersAdapterWrapper<C> {
343343
.get(&subgraph_filter.subgraph)
344344
.ok_or_else(|| anyhow!("Store not found for subgraph: {}", subgraph_filter.subgraph))?;
345345

346-
let schema = crate::components::store::ReadStore::input_schema(store);
346+
let schema = <dyn crate::components::store::SourceableStore>::input_schema(store);
347347

348348
let adapter = self.adapter.clone();
349349

@@ -401,7 +401,7 @@ pub enum SubgraphTriggerScanRange<C: Blockchain> {
401401

402402
async fn scan_subgraph_triggers<C: Blockchain>(
403403
logger: &Logger,
404-
store: &Arc<dyn WritableStore>,
404+
store: &Arc<dyn SourceableStore>,
405405
adapter: &Arc<dyn TriggersAdapter<C>>,
406406
schema: &InputSchema,
407407
filter: &SubgraphFilter,
@@ -435,7 +435,7 @@ pub struct EntityWithType {
435435
}
436436

437437
async fn get_entities_for_range(
438-
store: &Arc<dyn WritableStore>,
438+
store: &Arc<dyn SourceableStore>,
439439
filter: &SubgraphFilter,
440440
schema: &InputSchema,
441441
from: BlockNumber,

0 commit comments

Comments
 (0)