pub async fn run_query_subscription( gateway: &str, all_conn: bool, format: OutputFormat, ) -> Result<()>