diff --git a/nt-be/Cargo.lock b/nt-be/Cargo.lock
index 86bdac65..9cbd601f 100644
--- a/nt-be/Cargo.lock
+++ b/nt-be/Cargo.lock
@@ -2879,6 +2879,7 @@ dependencies = [
  "hex",
  "hmac 0.12.1",
  "jsonwebtoken",
+ "log",
  "moka",
  "near-account-id",
  "near-api",
diff --git a/nt-be/Cargo.toml b/nt-be/Cargo.toml
index 6381879b..2bc18af2 100644
--- a/nt-be/Cargo.toml
+++ b/nt-be/Cargo.toml
@@ -23,6 +23,7 @@ hex = "0.4"
 serde_with = { version = "3.16.1", features = ["base64"] }
 chrono = "0.4"
 futures = "0.3"
+log = "0.4"
 async-stream = "0.3"
 governor = "0.7"
 sqlx = { version = "0.8", features = [
diff --git a/nt-be/src/app_state.rs b/nt-be/src/app_state.rs
index f40617bd..59f03d50 100644
--- a/nt-be/src/app_state.rs
+++ b/nt-be/src/app_state.rs
@@ -1,7 +1,9 @@
 use axum::http::StatusCode;
 use chrono::{DateTime, Utc};
 use near_api::{AccountId, NetworkConfig, RPCEndpoint, Signer};
+use sqlx::ConnectOptions as _;
 use sqlx::PgPool;
+use std::str::FromStr as _;
 use std::{sync::Arc, time::Duration};
 use tokio::sync::broadcast;
 
@@ -511,6 +513,24 @@ impl AppState {
             .and_then(|v| v.parse::<u64>().ok())
             .filter(|v| *v >= 1)
             .unwrap_or(10);
+        // Slow-statement WARN threshold. sqlx defaults to 1s, which is too
+        // sensitive for this workload — the apalis-board admin pages run heavy
+        // full-table analytics over `apalis.jobs` (the `/overview` and `/queues`
+        // aggregates take ~1.5s) and legitimately warn on every load. Raise it
+        // (default 5s, `DB_SLOW_STATEMENT_THRESHOLD_SECONDS`) so routine
+        // multi-second analytics don't spam WARN while genuinely pathological
+        // statements (the seconds-long token/backfill queries) still surface.
+        let slow_statement_secs = std::env::var("DB_SLOW_STATEMENT_THRESHOLD_SECONDS")
+            .ok()
+            .and_then(|v| v.parse::<u64>().ok())
+            .filter(|v| *v >= 1)
+            .unwrap_or(5);
+        let connect_options = sqlx::postgres::PgConnectOptions::from_str(&env_vars.database_url)
+            .map_err(|e| format!("invalid DATABASE_URL: {e}"))?
+            .log_slow_statements(
+                log::LevelFilter::Warn,
+                Duration::from_secs(slow_statement_secs),
+            );
         tracing::info!(max_connections, "Connecting to database...");
         let db_pool = sqlx::postgres::PgPoolOptions::new()
             .max_connections(max_connections)
@@ -519,7 +539,7 @@ impl AppState {
             .idle_timeout(Duration::from_secs(600))
             .max_lifetime(Duration::from_secs(1800))
             .test_before_acquire(true)
-            .connect(&env_vars.database_url)
+            .connect_with(connect_options)
             .await?;
 
         tracing::info!("Running database migrations...");