fix: spawn a background connection thread

GreptimeTeam · Dec 20, 2024 · 30bab10 · 30bab10
1 parent 4ef9166
commit 30bab10
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/src/meta-srv/src/bootstrap.rs b/src/meta-srv/src/bootstrap.rs
@@ -288,8 +288,15 @@ async fn create_postgres_client(opts: &MetasrvOptions) -> Result<tokio_postgres:
     let postgres_url = opts.store_addrs.first().context(InvalidArgumentsSnafu {
         err_msg: "empty store addrs",
     })?;
-    let (client, _) = tokio_postgres::connect(postgres_url, NoTls)
+    let (client, connection) = tokio_postgres::connect(postgres_url, NoTls)
         .await
         .context(error::ConnectPostgresSnafu)?;
+
+    tokio::spawn(async move {
+        connection
+            .await
+            .context(error::PostgresExecutionSnafu)
+            .unwrap()
+    });
     Ok(client)
 }
diff --git a/src/meta-srv/src/election/postgres.rs b/src/meta-srv/src/election/postgres.rs
@@ -304,7 +304,7 @@ mod tests {
             }
             .fail();
         }
-        let (client, connection) = tokio_postgres::connect(&addr, NoTls)
+        let (client, connection) = tokio_postgres::connect(addr, NoTls)
             .await
             .context(PostgresExecutionSnafu)?;
         tokio::spawn(async move {