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

cargo fmt

This commit is contained in:
Serge Farnye 2024-04-03 11:39:17 +02:00
parent 92ca014313
commit 034a46d5e9
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
bin/service-mango-health/src/processors/data.rs
View File

@ -54,8 +54,10 @@ impl DataProcessor {
) -> anyhow::Result<DataProcessor> {
let mut retry_counter = RetryCounter::new(2);
let mango_group = Pubkey::from_str(&configuration.mango_group)?;
let (mango_stream, snapshot_job) =
fail_or_retry!(retry_counter, Self::init_mango_source(configuration, exit.clone()).await)?;
let (mango_stream, snapshot_job) = fail_or_retry!(
retry_counter,
Self::init_mango_source(configuration, exit.clone()).await
)?;
let (sender, _) = tokio::sync::broadcast::channel(8192);
let sender_clone = sender.clone();
@ -141,7 +143,7 @@ impl DataProcessor {
return Some(Snapshot(SnapshotEvent {
accounts: result,
received_at,
is_full: snapshot_type == SnapshotType::Full
is_full: snapshot_type == SnapshotType::Full,
}));
}
_ => {}