async fn query_flow_state( query_stat_size: &Option<SizeReportSender>, timeout: Duration, ) -> Option<FlowStat>