File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed
src/memos/mem_scheduler/utils Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change 66
77from dataclasses import dataclass , field
88
9+ from memos .log import get_logger
10+
911
1012# ==== global window config ====
1113WINDOW_SEC = 120 # 2 minutes sliding window
1214
15+ logger = get_logger (__name__ )
16+
1317
1418# ---------- O(1) EWMA ----------
1519class Ewma :
@@ -187,7 +191,7 @@ def on_enqueue(
187191 old_lam = ls .lambda_ewma .value_at (now )
188192 ls .lambda_ewma .update (inst_rate , now )
189193 new_lam = ls .lambda_ewma .value_at (now )
190- print (
194+ logger . info (
191195 f"[DEBUG enqueue] { label } backlog={ ls .backlog } dt={ dt if dt is not None else '—' } s inst={ inst_rate :.3f} λ { old_lam :.3f} →{ new_lam :.3f} "
192196 )
193197 self ._label_topk [label ].add (mem_cube_id )
@@ -225,7 +229,7 @@ def on_done(
225229 old_mu = ls .mu_ewma .value_at (now )
226230 ls .mu_ewma .update (inst_rate , now )
227231 new_mu = ls .mu_ewma .value_at (now )
228- print (
232+ logger . info (
229233 f"[DEBUG done] { label } backlog={ ls .backlog } dt={ dt if dt is not None else '—' } s inst={ inst_rate :.3f} μ { old_mu :.3f} →{ new_mu :.3f} "
230234 )
231235 ds = self ._detail_stats .get ((label , mem_cube_id ))
You can’t perform that action at this time.
0 commit comments