async fn verify_pool_state_task<P: Provider<Ethereum> + 'static, DB: DatabaseKabuExt>( client: P, address: PoolId, market_state: Arc<RwLock<MarketState<DB>>>, ) -> Result<()>