feat(flow): add Kalki-backed persistence checkpointer (#4644)#4732
Closed
yuweuii wants to merge 2 commits into
Closed
feat(flow): add Kalki-backed persistence checkpointer (#4644)#4732yuweuii wants to merge 2 commits into
yuweuii wants to merge 2 commits into
Conversation
Contributor
|
Hi! We are generally not accepting any external tool additions at the moment. Please see https://docs.crewai.com/en/guides/tools/publish-custom-tools |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
This PR implements issue #4644.
Linked Issue
Closes #4644
Note
Medium Risk
Adds a new non-default persistence backend that checkpoints and restores flow state (including async pending-feedback resume markers) via external gRPC service calls, which could affect flow recovery behavior and introduce dependency/compatibility issues with Kalki protos.
Overview
Adds an optional Kalki-backed flow persistence backend (
KalkiFlowPersistence) that checkpoints flow state to a running Kalki service via gRPC and restores the latest checkpoint by querying and timestamp-sorting stored log payloads.The new backend also supports async human-feedback resume by writing pending-feedback markers and clearing them via an append-only tombstone entry, and it is exported from
crewai.flow.persistenceand documented in the Flows persistence guide with a usage example.Written by Cursor Bugbot for commit 10e3c2c. This will update automatically on new commits. Configure here.