Telegram_listener PSL bug — juurpõhjuse audit (koord22)

1. Eesmärk + 3 hüpoteesi seisukord

Tuvastada juurpõhjus, miks telegram_listener.py cron-loop jätab process_state_log (PSL) read 'running' last_heartbeat vana, AGA agent_runs (AR) vastav rida saab kuidagi 'failed'/'completed'. Koord 22 leitud 63 orphan PSL (61× eirik_os.telegram_listener + 2× claude_code.session).

VERDICT: Kombinatsioon A + C — A = koord22 juurpõhjus, C = tuleviku probleemi-allikas.

2. Andmed — orphan PSL count + mustrid

2.1 Telegram_listener AR-id koord22 päeval (2026-05-27)

2.2 AR ↔ PSL muster (kõik telegram_listener AR-id)

2.3 Kahe erilise juhtumi detail (AR='failed' + PSL='completed')

AR id=111: started 2026-05-27 13:55:13 → PSL finished 14:19:01 (graceful) → AR mass-cleanup 19:13:17
            run_duration: 5h 18min · psl_close_delay: -4h 54min (PSL sulgus AR-ist enne)
AR id=113: started 2026-05-27 14:00:13 → PSL finished 14:19:01 (graceful) → AR mass-cleanup 19:13:17
            run_duration: 5h 13min · psl_close_delay: -4h 54min

See on vastupidine orphan PSL-le: PSL sulgus, AR jäi 'running'. Tõenäoselt mõlemad daemon-id said SIGINT (Ctrl+C-iga 14:19:01) → state.finish(status='completed') sõidetud → mõlemad UPDATE-id õnnestusid. AGA hiljem mass-cleanup SQL UPDATE puudutas mõlemaid AR-i (filter WHERE stage='telegram_listener' AND status='failed' OR 'running' VÕI lihtsalt sai veerul stage=telegram_listener mass-kasvataja).

2.4 Praegune seis

NOW UTC: 2026-05-27 21:55:56
open_psl_telegram: 1 (PSL id=256, last_heartbeat 21:55:35 — TERVE)
open_ar_telegram:  1 (AR id=268, started 19:19:02)

✅ Orphan PSL count = 0 — koord22 R4 puhastus + _is_already_running() idempotency-fix ennetab uut kasvu.

3. Juurpõhjuse mehhanism (rekonstrueeritud)

4. Lahenduse-tegevused (KANDIDAAT — ei rakendatud read-only mode-s)

4.1 KOHE — agent_state.AgentRunState.finish() migreerima atomic RPC-le

Põhjus: Tulevikus võib mistahes daemon (mitte ainult telegram_listener) langeda Hypothesis C all — kui shutdown'i ajal step 1 (PSL UPDATE) saab võrgu-erroriga, AR sulgub edukalt aga PSL jääb 'running' = uus orphan PSL.

Lahendus-kandidaat: eirik_os/agent_state.py read 437-505 finish() meetod → kutsub tier_2_5_helper.finish()-le mille all on Migration 0060 atomic RPC tier_2_5_finish (LIVE kinnitatud information_schema.routines kontrolliga).

def finish(self, status="completed", exit_code=0, counts=None, summary=None, error=None, cost_usd=0.0) -> None:
    if not self.enabled or self.run_id is None or self.process_state_id is None:
        return
    try:
        from eirik_os.tier_2_5_helper import finish as _atomic_finish
        _atomic_finish(
            state={"agent_run_id": self.run_id, "process_state_id": self.process_state_id, "agent_id": self.agent_id},
            status=status,
            summary_merge=summary,
            exit_code=exit_code,
            error=error,
            release_locks=True,
        )
    except Exception as e:
        log.warning("Atomic finish ebaõnnestus — fallback non-atomic: %s", e)
        # ... olemasolev 2-step kood ...

Tee: Edit 07_skriptid/eirik_os/agent_state.py + register_edit + pos_deep_memory category='otsus' ENNE muudatust + Erki kinnitus (PR #111 strateegiline — mõjutab 5+ agendi-rolli K0).

4.2 KOHE — telegram_listener.py robustsem shutdown

Põhjus: Windows TerminateProcess / Task Scheduler "End task" bypassi SIGTERM. atexit + SIGBREAK lisamine ennetab no-finish-call juhtumit.

import atexit

def _final_finish():
    """atexit hook — viimase rea kindlustaja kui SIGTERM/SIGINT ei tulnud."""
    global state
    if state and state.run_id:
        try:
            state.finish(status="partial", error="atexit_no_signal")
        except Exception:
            pass

atexit.register(_final_finish)

# Lisaks signal_handler-i SIGBREAK (Windows)
if hasattr(signal, "SIGBREAK"):
    signal.signal(signal.SIGBREAK, _signal_handler)

4.3 KÕRGEM PRIORITEET — Vahimees heartbeat_watcher.kill_stale_run atomic

Põhjus: 4-step sequential UPDATE (read 219-273) — kui step 2 (PSL UPDATE) fail, log.warning ainult AGA AR juba 'failed'. Eraldi orphan PSL allikas.

Kandidaat-SQL: Migration 0064+ — kill_stale_run_atomic(p_run_id, p_kill_reason, p_release_locks) RPC stiilis tier_2_5_finish:

CREATE OR REPLACE FUNCTION kill_stale_run_atomic(
  p_run_id BIGINT, p_kill_reason TEXT, p_release_locks BOOL DEFAULT TRUE
) RETURNS JSONB LANGUAGE plpgsql AS $$
DECLARE
  v_psl_id BIGINT;
  v_agent_id TEXT;
  v_locks_released INT := 0;
BEGIN
  SELECT process_state_id, agent_id INTO v_psl_id, v_agent_id
  FROM agent_runs WHERE id = p_run_id;

  UPDATE agent_runs SET status='failed', finished_at=NOW(), error_message=p_kill_reason
   WHERE id = p_run_id;

  IF v_psl_id IS NOT NULL THEN
    UPDATE process_state_log SET status='killed', finished_at=NOW()
     WHERE id = v_psl_id;
  END IF;

  IF p_release_locks THEN
    WITH del AS (
      DELETE FROM agent_task_locks WHERE locked_run_id = p_run_id RETURNING 1
    ) SELECT COUNT(*) INTO v_locks_released FROM del;
  END IF;

  RETURN jsonb_build_object(
    'run_id', p_run_id,
    'psl_id', v_psl_id,
    'agent_id', v_agent_id,
    'locks_released', v_locks_released
  );
END $$;

Esitatakse Erkile agent_messages priority=2 + pos_deep_memory category='otsus' järgmise sessiooni kandidaadina.

5. Ennetuse plaan (Vahimees uuendused)

6. PR #129/#130 seisukord seoses bug-iga

• PR #129 (Migration 0060 atomic RPC) — KÕIGE PARANDUS — kui telegram_listener (ja kõik teised daemon-id) kasutaks tier_2_5_helper-i (mitte vana eirik_os.agent_state-i), siis Hypothesis C ei oleks võimalik. Migration 0060 LIVE (kontrollitud information_schema.routines), AGA agent_state.py ei kasuta seda. Konsolideerumine vajalik.
• PR #130 (M2 MCPDoctor laiend) — ei mõjuta seda bug-i otseselt, AGA aitab tuvastada Tier 2 timeout-i (Supabase 502) mis võiks põhjustada Hypothesis C step 1 fail.

7. Audit-jälg (PR #115 sub-spawn kohustused)

• agent_runs id=268 — praegune LIVE telegram_listener daemon (TERVE, viimane heartbeat 21:55:35)
• agent_runs id=266 — viimane killed_ghost AR enne praegust daemon-i
• agent_messages id=4531 — Vahimees zombie kill 2026-05-27 15:20 telegram_listener (run_id=115)
• Skripti-faili audit: 4 faili loetud ainult (telegram_listener.py, heartbeat_watcher.py, agent_state.py, tier_2_5_helper.py) — ühtegi muudatust ei tehtud. read-only mode.
• register_edit: 1 kanne (HTML raport loomine) — vt system_edit_registry.jsonl