This is an automated email from the ASF dual-hosted git repository. skrawcz pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/burr.git
commit 9427dc5cce45f97319f690722a1af1fd97bd7c4b Author: goutamk09 <[email protected]> AuthorDate: Tue Jan 13 14:03:43 2026 +0530 Add override_state_values support to initialize_from --- burr/core/application.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/burr/core/application.py b/burr/core/application.py index 55f98acf..70fa54e4 100644 --- a/burr/core/application.py +++ b/burr/core/application.py @@ -2424,6 +2424,7 @@ class ApplicationBuilder(Generic[StateType]): fork_from_app_id: str = None, fork_from_partition_key: str = None, fork_from_sequence_id: int = None, + override_state_values: Optional[dict] = None, ) -> "ApplicationBuilder[StateType]": """Initializes the application we will build from some prior state object. @@ -2460,6 +2461,7 @@ class ApplicationBuilder(Generic[StateType]): self.fork_from_app_id = fork_from_app_id self.fork_from_partition_key = fork_from_partition_key self.fork_from_sequence_id = fork_from_sequence_id + self.override_state_values = override_state_values return self def with_state_persister( @@ -2614,6 +2616,9 @@ class ApplicationBuilder(Generic[StateType]): # there was something last_position = load_result["position"] self.state = load_result["state"] + if getattr(self, "override_state_values", None): + self.state = self.state.update(**self.override_state_values) + self.sequence_id = load_result["sequence_id"] status = load_result["status"] if self.resume_at_next_action:
