From 66721459223cffcd0fbe4f1f4acede731222bb31 Mon Sep 17 00:00:00 2001 From: Nathan Flurry Date: Fri, 14 Jun 2024 21:16:13 +0000 Subject: [PATCH] chore: increase sql conn acquire rate limits --- lib/pools/src/utils/sql_query_macros.rs | 8 ++++---- svc/pkg/cluster/standalone/default-update/src/lib.rs | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/lib/pools/src/utils/sql_query_macros.rs b/lib/pools/src/utils/sql_query_macros.rs index c96b14ecc..0ea5f3f93 100644 --- a/lib/pools/src/utils/sql_query_macros.rs +++ b/lib/pools/src/utils/sql_query_macros.rs @@ -6,10 +6,10 @@ lazy_static::lazy_static! { governor::clock::DefaultClock, governor::middleware::NoOpMiddleware > = governor::RateLimiter::direct( - // Limit how many connections can be created to the database - governor::Quota::per_second(std::num::NonZeroU32::new(16).unwrap()) - // Allow creating at most 5 connections at the same time - .allow_burst(std::num::NonZeroU32::new(256).unwrap()) + // Limit how fast the pool size can grow in order to encourage reusuing existing + // connections instead of opening new ones. + governor::Quota::per_minute(std::num::NonZeroU32::new(10 * 60).unwrap()) + .allow_burst(std::num::NonZeroU32::new(500).unwrap()) ); } diff --git a/svc/pkg/cluster/standalone/default-update/src/lib.rs b/svc/pkg/cluster/standalone/default-update/src/lib.rs index f0a3e4e2c..59cc69082 100644 --- a/svc/pkg/cluster/standalone/default-update/src/lib.rs +++ b/svc/pkg/cluster/standalone/default-update/src/lib.rs @@ -186,8 +186,8 @@ pub async fn run_from_env(use_autoscaler: bool) -> GlobalResult<()> { .into_iter() .map(|(pool_type, pool)| { let desired_count = match pool_type { - PoolType::Ats => Some(pool.desired_count), - PoolType::Job | PoolType::Gg => { + PoolType::Ats | PoolType::Gg => Some(pool.desired_count), + PoolType::Job => { if use_autoscaler { None } else {