diff --git a/scripts/api.py b/scripts/api.py index d64eed1..8d059d0 100644 --- a/scripts/api.py +++ b/scripts/api.py @@ -518,13 +518,13 @@ def _push_chat_turn_to_graphiti(conversation_id, user_message, assistant_message # is empirically ~20 min wall-clock. We're patient; chat isn't. r = requests.post(f"{GRAPHITI_URL}/episodes", json=payload, timeout=1800) if r.status_code == 200: - print(f"[graphiti-push] turn ingested: {episode_name}") + print(f"[graphiti-push] turn ingested: {episode_name}", flush=True) else: - print(f"[graphiti-push] non-200 ({r.status_code}) for {episode_name}: {r.text[:200]}") + print(f"[graphiti-push] non-200 ({r.status_code}) for {episode_name}: {r.text[:200]}", flush=True) except requests.RequestException as e: - print(f"[graphiti-push] request failed: {e}") + print(f"[graphiti-push] request failed: {e}", flush=True) except Exception as e: - print(f"[graphiti-push] unexpected error: {e}") + print(f"[graphiti-push] unexpected error: {e}", flush=True) threading.Thread(target=_work, daemon=True).start()