fix futures

graphprotocol · Dec 6, 2024 · d8eb30e · d8eb30e
1 parent e657797
commit d8eb30e
Showing 1 changed file with 9 additions and 6 deletions.
diff --git a/graph/src/blockchain/block_stream.rs b/graph/src/blockchain/block_stream.rs
@@ -546,13 +546,16 @@ impl<C: Blockchain> TriggersAdapterWrapper<C> {
             return self.adapter.chain_head_ptr().await;
         }
 
-        let ptr = self
-            .source_subgraph_stores
-            .iter()
-            .filter_map(|(_, store)| store.block_ptr())
-            .min_by_key(|ptr| ptr.number);
+        let ptrs = futures03::future::try_join_all(
+            self.source_subgraph_stores
+                .iter()
+                .map(|(_, store)| store.block_ptr()),
+        )
+        .await?;
+
+        let min_ptr = ptrs.into_iter().flatten().min_by_key(|ptr| ptr.number);
 
-        Ok(ptr)
+        Ok(min_ptr)
     }
 }