blockworks-foundation
/
lite-rpc
mirror of https://github.com/blockworks-foundation/lite-rpc.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #93 from blockworks-foundation/postgres_channel_fix 

don't return on session error
This commit is contained in:
galactus 2023-03-22 10:30:02 +01:00 committed by GitHub
parent 8e5cf8a567 ec13502428
commit eb608f1d8f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/workers/postgres.rs
View File

@ -1,6 +1,6 @@
use std::sync::Arc;
use std::{sync::Arc, time::Duration};
use anyhow::{bail, Context, Ok};
use anyhow::{bail, Context};
use log::{info, warn};
use postgres_native_tls::MakeTlsConnector;
@ -235,8 +235,14 @@ impl Postgres {
info!("Writing to postgres");
while let Some(msg) = recv.recv().await {
let Ok(session) = self.get_session().await else {
const TIME_OUT:Duration = Duration::from_millis(1000);
warn!("Unable to get postgres session. Retrying in {TIME_OUT:?}");
tokio::time::sleep(TIME_OUT).await;
continue;
};
MESSAGES_IN_POSTGRES_CHANNEL.dec();
let session = self.get_session().await?;
let Err(err) = (
match msg {