minor changes
This commit is contained in:
parent
eedebd9ff4
commit
b1277ac5fe
17
src/main.rs
17
src/main.rs
|
@ -147,6 +147,15 @@ pub async fn main() -> anyhow::Result<()> {
|
|||
.iter()
|
||||
.map(|x| Pubkey::from_str(x.as_str()).unwrap())
|
||||
.collect();
|
||||
|
||||
clean_market_makers(
|
||||
nb_rpc_client.clone(),
|
||||
&account_keys_parsed,
|
||||
&perp_market_caches,
|
||||
blockhash.clone(),
|
||||
)
|
||||
.await;
|
||||
|
||||
// start keeper if keeper authority is present
|
||||
let keepers_jl = if let Some(keeper_authority) = keeper_authority {
|
||||
let jl = start_keepers(
|
||||
|
@ -183,13 +192,7 @@ pub async fn main() -> anyhow::Result<()> {
|
|||
);
|
||||
|
||||
let warmup_duration = Duration::from_secs(10);
|
||||
clean_market_makers(
|
||||
nb_rpc_client.clone(),
|
||||
&account_keys_parsed,
|
||||
&perp_market_caches,
|
||||
blockhash.clone(),
|
||||
)
|
||||
.await;
|
||||
|
||||
info!("waiting for keepers to warmup for {warmup_duration:?}");
|
||||
tokio::time::sleep(warmup_duration).await;
|
||||
|
||||
|
|
|
@ -352,5 +352,5 @@ pub async fn clean_market_makers(
|
|||
}
|
||||
|
||||
futures::future::join_all(tasks).await;
|
||||
info!("finished cleaning");
|
||||
info!("finished cleaning market makers");
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue