From a3d25c661a7fdd9f3d00d20c1953d1ff9269fe3d Mon Sep 17 00:00:00 2001 From: Greyson LaLonde Date: Sat, 4 Apr 2026 03:09:57 +0800 Subject: [PATCH] fix: register RuntimeState in Flow.from_checkpoint Crew.from_checkpoint called set_runtime_state but Flow.from_checkpoint did not, leaving the event bus without the restored state. --- lib/crewai/src/crewai/flow/flow.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/lib/crewai/src/crewai/flow/flow.py b/lib/crewai/src/crewai/flow/flow.py index ed1eda7e5..848743ba2 100644 --- a/lib/crewai/src/crewai/flow/flow.py +++ b/lib/crewai/src/crewai/flow/flow.py @@ -927,6 +927,7 @@ class Flow(BaseModel, Generic[T], metaclass=FlowMeta): ) -> Flow: # type: ignore[type-arg] """Restore a Flow from a checkpoint file.""" from crewai.context import apply_execution_context + from crewai.events.event_bus import crewai_event_bus from crewai.state.provider.json_provider import JsonProvider from crewai.state.runtime import RuntimeState @@ -935,6 +936,7 @@ class Flow(BaseModel, Generic[T], metaclass=FlowMeta): provider=provider or JsonProvider(), context={"from_checkpoint": True}, ) + crewai_event_bus.set_runtime_state(state) for entity in state.root: if isinstance(entity, cls): if entity.execution_context is not None: