pub(super) async fn run_query_inner(
timeout_duration: u64,
client: &Client,
query: &str,
skip_timeout: bool,
) -> Result<(i64, Vec<SimpleQueryMessage>)>Expand description
Run query, handle permissible errors For recovery error, just do bounded retry. For other errors, validate them accordingly, skipping if they are permitted. Otherwise just return success. If takes too long return the query which timed out + execution time + timeout error Returns: Number of skipped queries, number of rows returned.