Skip to content

Commit 3e8d3e9

Browse files
store: Asyncify deployment_sizes()
Signed-off-by: Maksim Dimitrov <dimitrov.maksim@gmail.com>
1 parent 67b6307 commit 3e8d3e9

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

store/postgres/src/detail.rs

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -437,7 +437,7 @@ pub(crate) async fn deployment_statuses(
437437
.collect()
438438
};
439439

440-
let mut deployment_sizes = deployment_sizes(conn, sites)?;
440+
let mut deployment_sizes = deployment_sizes(conn, sites).await?;
441441

442442
details_with_fatal_error
443443
.into_iter()
@@ -458,8 +458,8 @@ pub(crate) async fn deployment_statuses(
458458
.collect()
459459
}
460460

461-
fn deployment_sizes(
462-
conn: &mut PgConnection,
461+
async fn deployment_sizes(
462+
conn: &mut AsyncPgConnection,
463463
sites: &[Arc<Site>],
464464
) -> Result<HashMap<DeploymentId, status::SubgraphSize>, StoreError> {
465465
#[derive(QueryableByName)]
@@ -493,12 +493,13 @@ fn deployment_sizes(
493493
);
494494

495495
let result = if sites.is_empty() {
496-
diesel::sql_query(query).load::<SubgraphSizeRow>(conn)
496+
diesel::sql_query(query).load::<SubgraphSizeRow>(conn).await
497497
} else {
498498
query.push_str(" WHERE ds.id = ANY($1)");
499499
diesel::sql_query(query)
500500
.bind::<Array<Integer>, _>(sites.iter().map(|site| site.id).collect::<Vec<_>>())
501501
.load::<SubgraphSizeRow>(conn)
502+
.await
502503
};
503504

504505
let rows = match result {

0 commit comments

Comments
 (0)