Adding check to reconcile quota values in postgres only when it changes in configmap.

Author: sriroopar

ols/runners/quota_scheduler.py

@@ -13,6 +13,9 @@
 
 logger: logging.Logger = logging.getLogger(__name__)
 
+# Track last reconciled quota values to avoid DB updates when quota is unchanged
+_last_reconciled_quotas: dict[str, int] = {}
+
 
 INCREASE_QUOTA_STATEMENT = """
     UPDATE quota_limits
@@ -186,6 +189,12 @@ def reconcile_quota_limits(
         logger.debug("No initial quota set for '%s', skipping reconciliation", name)
         return
 
+    # Check if quota value has changed since last reconciliation, to remove redundant checks
+    new_quota = quota_limiter.initial_quota
+    if name in _last_reconciled_quotas and _last_reconciled_quotas[name] == new_quota:
+        logger.debug("Quota unchanged for '%s' (value=%d), skipping reconciliation", name, new_quota)
+        return
+
     # Select appropriate SQL based on limiter type
     if quota_limiter.type == constants.USER_QUOTA_LIMITER:
         reconcile_sql = RECONCILE_USER_QUOTA_LIMITS_STATEMENT
@@ -199,8 +208,6 @@ def reconcile_quota_limits(
         )
         return
 
-    new_quota = quota_limiter.initial_quota
-
     try:
         with connection.cursor() as cursor:
             cursor.execute(
@@ -237,6 +244,9 @@ def reconcile_quota_limits(
                     "(no records or all match current configuration)",
                     name,
                 )
+
+            # Tracking quota value
+            _last_reconciled_quotas[name] = new_quota
     except Exception as e:
         logger.error(
             "Failed to reconcile quota limits for '%s': %s",