diff --git a/keeper/src/consume_events.rs b/keeper/src/consume_events.rs index 2bc4dedbd..5eef56ffd 100644 --- a/keeper/src/consume_events.rs +++ b/keeper/src/consume_events.rs @@ -19,7 +19,9 @@ pub async fn loop_blocking(mango_client: Arc, pk: Pubkey, perp_mark let client = mango_client.clone(); tokio::task::spawn_blocking(move || { perform_operation(client, pk, perp_market).expect("Something went wrong here..."); - }); + }) + .await + .expect("Something went wrong here..."); } } diff --git a/keeper/src/update_index.rs b/keeper/src/update_index.rs index ab64888a9..39dac4ec9 100644 --- a/keeper/src/update_index.rs +++ b/keeper/src/update_index.rs @@ -14,7 +14,9 @@ pub async fn loop_blocking(mango_client: Arc, pk: Pubkey, bank: Ban let client = mango_client.clone(); tokio::task::spawn_blocking(move || { perform_operation(client, pk, bank).expect("Something went wrong here..."); - }); + }) + .await + .expect("Something went wrong here..."); } }