Skip to content

Commit 13bfeda

Browse files
committed
store: Use AsyncPgConnection for PoolInner.locale_check
1 parent c24580f commit 13bfeda

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

store/postgres/src/pool/mod.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -602,11 +602,11 @@ impl PoolInner {
602602
async fn locale_check(
603603
&self,
604604
logger: &Logger,
605-
mut conn: PgConnection,
605+
conn: &mut AsyncPgConnection,
606606
) -> Result<(), StoreError> {
607607
Ok(
608-
if let Err(msg) = catalog::Locale::load(&mut conn).await?.suitable() {
609-
if &self.shard == &*PRIMARY_SHARD && primary::is_empty(&mut conn).await? {
608+
if let Err(msg) = catalog::Locale::load(conn).await?.suitable() {
609+
if &self.shard == &*PRIMARY_SHARD && primary::is_empty(conn).await? {
610610
const MSG: &str =
611611
"Database does not use C locale. \
612612
Please check the graph-node documentation for how to set up the database locale";
@@ -678,7 +678,7 @@ impl PoolInner {
678678
})
679679
.await?;
680680

681-
this.locale_check(&this.logger, conn).await?;
681+
this.locale_check(&this.logger, &mut conn).await?;
682682

683683
Ok(count)
684684
}

0 commit comments

Comments
 (0)