diff --git a/cats/cats-sql/src/main/kotlin/com/netflix/spinnaker/cats/sql/cluster/SqlClusteredAgentScheduler.kt b/cats/cats-sql/src/main/kotlin/com/netflix/spinnaker/cats/sql/cluster/SqlClusteredAgentScheduler.kt index f368cc9c898..2acc653ebe3 100644 --- a/cats/cats-sql/src/main/kotlin/com/netflix/spinnaker/cats/sql/cluster/SqlClusteredAgentScheduler.kt +++ b/cats/cats-sql/src/main/kotlin/com/netflix/spinnaker/cats/sql/cluster/SqlClusteredAgentScheduler.kt @@ -236,7 +236,7 @@ class SqlClusteredAgentScheduler( val newTtl = nextExecutionTime - System.currentTimeMillis() withPool(POOL_NAME) { - if (newTtl < 500L) { + if (newTtl < dynamicConfigService.getConfig(Long::class.java, "sql.agent.release-threshold-ms", 500)) { try { jooq.delete(table(lockTable)).where(field("agent_name").eq(agentType)).execute() } catch (e: SQLException) {