diff --git a/src/agentic_pd_hybrid/replay.py b/src/agentic_pd_hybrid/replay.py index 4410c78..f77c32d 100644 --- a/src/agentic_pd_hybrid/replay.py +++ b/src/agentic_pd_hybrid/replay.py @@ -2356,19 +2356,10 @@ async def _invoke_kvcache_seeded_router( prefill_url=prefill_url, decode_session=decode_session, ) - if sync_result is not None and sync_result.get("status") != "ok": - logger.info( - "d_to_p_sync sid=%s rid=%s skipped: %s", - request.session_id, request.request_id, sync_result, - ) - elif sync_result and sync_result.get("status") == "ok": - logger.info( - "d_to_p_sync sid=%s rid=%s pushed=%d ingested_prefix=%d", - request.session_id, - request.request_id, - sync_result.get("bytes_pushed", 0), - sync_result.get("inserted_prefix_len", 0), - ) + # NB: every outcome of _attempt_d_to_p_sync is already captured in + # structural/d-to-p-sync.jsonl via _structural_emit. No need for an + # additional logger.info here (and `logger` isn't imported at module + # scope, so it would NameError if reached). decode_session_newly_opened = False try: