Skip to content

Commit 233f155

Browse files
committed
store: Asyncify primary::Connection.get_subgraph_features
1 parent d164872 commit 233f155

File tree

3 files changed

+3
-2
lines changed

3 files changed

+3
-2
lines changed

store/postgres/src/primary.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1166,7 +1166,7 @@ impl Connection {
11661166
}
11671167
}
11681168

1169-
pub fn get_subgraph_features(
1169+
pub async fn get_subgraph_features(
11701170
&mut self,
11711171
id: String,
11721172
) -> Result<Option<DeploymentFeatures>, StoreError> {

store/postgres/src/subgraph_store.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1555,6 +1555,7 @@ impl SubgraphStoreTrait for SubgraphStore {
15551555
let mut pconn = self.primary_conn()?;
15561556
pconn
15571557
.get_subgraph_features(deployment)
1558+
.await
15581559
.map_err(|e| e.into())
15591560
}
15601561

store/test-store/tests/postgres/subgraph.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ async fn get_version_info(store: &Store, subgraph_name: &str) -> VersionInfo {
7474

7575
async fn get_subgraph_features(id: String) -> Option<DeploymentFeatures> {
7676
let mut primary = primary_connection().await;
77-
primary.get_subgraph_features(id).unwrap()
77+
primary.get_subgraph_features(id).await.unwrap()
7878
}
7979

8080
async fn latest_block(store: &Store, deployment_id: DeploymentId) -> BlockPtr {

0 commit comments

Comments
 (0)