İnsan onaylı iş akışları
İadeler, sözleşme değişiklikleri ve üretim dağıtımları, bir süreci açık tutmadan, dakikalarca veya günlerce bir kişinin onayını bekler.
LangGraph ajanlarını HotKV üzerinde kalıcı kılın. Grafik durumunda duraklatın, sürdürün ve zamanda yolculuk yapın; uzun vadeli belleği anlamla aranabilir tutun.
Kontrol noktası oluşturucu ve depo için tek paket. Python 3.10 veya daha yeni.
Gerçek HotKV komutları ve örnek yanıtlarla animasyonlu bir anlatım. Herhangi bir adıma atlamak için üzerine tıklayın. Komutlar ve yanıtlar, HotKV'de yazdığınız ve gördüğünüz haliyle İngilizce kalır.
Durumunu süreç belleğinde tutan bir LangGraph ajanı, yeniden başlatmada her şeyi kaybeder. İnsan onaylı akışlar bir gece bekleyemez, başarısız çalıştırmalar sürdürülemez ve ajanın öğrendiği hiçbir şey bir sonraki konuşmaya ulaşmaz.
langgraph-checkpoint-hotkv, her grafiğin kontrol noktalarını HotKV'de saklar. Bir grafik kesilip sürdürülebilir ya da önceki herhangi bir adıma geri sarılıp oradan dallandırılabilir. Eşlik eden depo, uzun vadeli belleği iş parçacıkları arasında tutar; ad alanına, filtreye veya bir embedding modeliyle anlama göre bulunur.
Kontrol noktası oluşturucu ve depo için tek paket. Python 3.10 veya daha yeni.
pip install langgraph-checkpoint-hotkvGrafiğin her adımı artık HotKV'de kaydedilir.
graph = builder.compile(checkpointer=HotKVSaver(hotkv.from_url("hotkv://localhost:6379")), interrupt_before=["refund"])Grafik adımlarını işler, her birinden sonra bir kontrol noktası kaydeder ve iadeden önce durur.
graph.invoke({"messages": [("user", "Refund order 1182")]}, {"configurable": {"thread_id": "t-81"}})Süreç gece boyunca yeniden başladı. Durum hâlâ HotKV'de, aynı adımda bekliyor.
graph.get_state({"configurable": {"thread_id": "t-81"}}).nextOnaylayıcı evet der ve grafik kaydedilen kontrol noktasından devam eder.
graph.invoke(None, {"configurable": {"thread_id": "t-81"}})Uzun vadeli bellek depoda yaşar ve sonraki herhangi bir konuşmada yeniden bulunur.
store.put(("users", "42"), "prefs", {"refunds": "prefers store credit"})İadeler, sözleşme değişiklikleri ve üretim dağıtımları, bir süreci açık tutmadan, dakikalarca veya günlerce bir kişinin onayını bekler.
40. adımda başarısız olan bir çalıştırma, baştan başlamak yerine 40. adımdan sürdürülür.
Önceki herhangi bir kontrol noktasına dönün, girdiyi değiştirin ve dallanın; ajanın nasıl davranacağını görün.
HotKVSaver ve AsyncHotKVSaver, kesme, sürdürme ve zamanda yolculukla grafik durumunu çalıştırmalar arasında tutar.
HotKVStore, öğeleri iş parçacıkları arasında tutar; ad alanına, filtreye veya anlama göre aranabilir, isteğe bağlı sona erme ile.
Her iki kaydedici için de LangGraph'ın kendi kontrol noktası uyumluluk paketini, 8 yetenekte 81 testi geçer.
HotKV'nin çekirdek veri türlerini ve vektör dizinini kullanır; kurumsal lisansla da lisanssız da çalışır.
from langgraph.checkpoint.hotkv import HotKVSaver
with HotKVSaver.from_conn_string("hotkv://localhost:6379") as checkpointer:
graph = builder.compile(checkpointer=checkpointer)
graph.invoke({"messages": [("user", "hi")]}, {"configurable": {"thread_id": "1"}})Hayır. Kontrol noktası oluşturucu ve depo HotKV'nin çekirdek veri türlerini ve vektör dizinini kullanır; lisanslı ya da lisanssız bir sunucuda çalışır.
Evet. AsyncHotKVSaver ve AsyncHotKVStore, ainvoke ve astream ile çalışır.
Evet. Her şey varsayılan olarak langgraph olan, uygulama veya ortam başına değiştirebileceğiniz bir anahtar öneki altında saklanır.
HotKV, Redis protokolünü konuşur; bu yüzden mevcut bir istemciyi ona yönlendirip aynı komutları çalıştırabilirsiniz.