From 8db9a842a8ef5780a131d1ba773ee64892d6a708 Mon Sep 17 00:00:00 2001 From: mdecimus Date: Tue, 9 Jan 2024 11:28:52 +0100 Subject: [PATCH] Parse mysql timeout.wait property as duration (closes #202) --- crates/store/src/backend/mysql/main.rs | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/crates/store/src/backend/mysql/main.rs b/crates/store/src/backend/mysql/main.rs index f1001afc..7aae0b55 100644 --- a/crates/store/src/backend/mysql/main.rs +++ b/crates/store/src/backend/mysql/main.rs @@ -21,6 +21,8 @@ * for more details. */ +use std::time::Duration; + use mysql_async::{prelude::Queryable, OptsBuilder, Pool, PoolConstraints, PoolOpts, SslOpts}; use utils::config::utils::AsKey; @@ -44,7 +46,11 @@ impl MysqlStore { .to_string() .into(), ) - .wait_timeout(config.property((&prefix, "timeout.wait"))?); + .wait_timeout( + config + .property::((&prefix, "timeout.wait"))? + .map(|t| t.as_secs() as usize), + ); if let Some(port) = config.property((&prefix, "port"))? { opts = opts.tcp_port(port); }