fix(volc_sync): retry apply loop logging changes
This commit is contained in:
+24
-31
@@ -699,39 +699,32 @@ def active_monitor_loop():
|
|||||||
else:
|
else:
|
||||||
targets = [model_name]
|
targets = [model_name]
|
||||||
|
|
||||||
# Whitelist Filter
|
|
||||||
final_targets_to_update = []
|
|
||||||
is_active_for_panic = False
|
|
||||||
|
|
||||||
for target in targets:
|
for target in targets:
|
||||||
matched = False
|
# Only set keys for models we are actually using (found in config)
|
||||||
if not INTERESTED_MODELS:
|
# BUT we must set ALL keys to ensure we don't miss any aliases.
|
||||||
matched = True
|
# Optimization: Check if target is in INTERESTED_MODELS
|
||||||
|
if target in INTERESTED_MODELS:
|
||||||
|
configured_models_found = True
|
||||||
|
|
||||||
|
# Use normalized key for storage
|
||||||
|
# Format: limit:dynamic:volcengine:remaining:{model_name}
|
||||||
|
dynamic_key = f"limit:dynamic:volcengine:remaining:{target}"
|
||||||
|
|
||||||
|
# Set with expiry (slightly longer than max interval)
|
||||||
|
redis_client.setex(dynamic_key, 7200, int(remaining))
|
||||||
|
print(
|
||||||
|
f"DEBUG: Set Redis {dynamic_key} = {int(remaining)}",
|
||||||
|
flush=True,
|
||||||
|
)
|
||||||
|
|
||||||
|
if remaining < temp_min_remaining:
|
||||||
|
temp_min_remaining = remaining
|
||||||
else:
|
else:
|
||||||
for interested in INTERESTED_MODELS:
|
if DEBUG_MODE:
|
||||||
if target == interested:
|
print(
|
||||||
matched = True
|
f"DEBUG: Skipping {target} (Not in INTERESTED_MODELS)",
|
||||||
elif target == model_name and (
|
flush=True,
|
||||||
target in interested or interested in target
|
)
|
||||||
):
|
|
||||||
matched = True
|
|
||||||
if matched:
|
|
||||||
break
|
|
||||||
|
|
||||||
if matched:
|
|
||||||
final_targets_to_update.append(target)
|
|
||||||
is_active_for_panic = True
|
|
||||||
|
|
||||||
if is_active_for_panic:
|
|
||||||
configured_models_found = True
|
|
||||||
if remaining < temp_min_remaining:
|
|
||||||
temp_min_remaining = remaining
|
|
||||||
|
|
||||||
# Update Redis
|
|
||||||
for target in final_targets_to_update:
|
|
||||||
key = f"limit:dynamic:volcengine:remaining:{target}"
|
|
||||||
redis_client.setex(key, 7200, int(remaining))
|
|
||||||
print(f"Updated {target}: Bal={balance:,} -> Rem={remaining:,}")
|
|
||||||
|
|
||||||
global_min_remaining = temp_min_remaining if model_balances else 0
|
global_min_remaining = temp_min_remaining if model_balances else 0
|
||||||
last_usage_map["global"] = current_usage_global
|
last_usage_map["global"] = current_usage_global
|
||||||
|
|||||||
Reference in New Issue
Block a user