ee781c00e2
Addresses Vineeth's review on #927. Blocking: - message_embeddings_pending is a DB-global count, so drive it from ReconcilerScheduler._scheduler_loop (runs on every replica, every interval) instead of run_vector_reconciliation_cycle (runs off the queue behind work-unit dedup, so one replica per cycle). Combined with the zero-init, the old placement made every replica that never won the work unit export a confident permanent 0. Help string now names the owner so dashboards don't reach for sum(). - guard initialize_telemetry_dropped_metrics on METRICS.ENABLED, matching its sibling initializer. - drop the duplicate REASONING_LEVELS; import the one in src/config. Non-blocking: - walk BaseSpecialist recursively via a shared utils.types.walk_subclasses (replaces the direct-children-only __subclasses__() and the test's private copy of the same helper). - derive the specialist assertion from the subclasses instead of hardcoding two names — the hardcoded pair kept passing after CardRefreshSpecialist landed, leaving it uncovered. - inline the zero-init rationale and the multi-instance bucket taxonomy; removes both pointers to a .meta design doc that is not in the repo. Tests: new tests/reconciler/test_pending_backlog_gauge.py pins both halves of the relocation (verified it fails when reverted). |
||
|---|---|---|
| .. | ||
| __init__.py | ||
| conftest.py | ||
| test_cross_agent_trace.py | ||
| test_embedding_call_event.py | ||
| test_embedding_trace.py | ||
| test_emit_function.py | ||
| test_emitter.py | ||
| test_events.py | ||
| test_langfuse_exporter.py | ||
| test_metric_zero_init.py | ||
| test_representation_v2_fields.py | ||
| test_sentry_before_send.py | ||
| test_sentry_sampler.py | ||
| test_summary_v2_fields.py | ||
| test_trace_events.py | ||