diff --git a/lib/crewai/src/crewai/crew.py b/lib/crewai/src/crewai/crew.py index d0963b513..c118d43b1 100644 --- a/lib/crewai/src/crewai/crew.py +++ b/lib/crewai/src/crewai/crew.py @@ -1632,7 +1632,7 @@ class Crew(FlowTrackable, BaseModel): def reset_knowledge(self, knowledges: list[Knowledge]) -> None: """Reset crew and agent knowledge storage.""" - for ks in knowledges: + def _reset_single_knowledge(ks: Knowledge) -> None: try: ks.reset() except Exception as e: @@ -1644,6 +1644,9 @@ class Crew(FlowTrackable, BaseModel): else: raise + for ks in knowledges: + _reset_single_knowledge(ks) + def _set_allow_crewai_trigger_context_for_first_task(self): crewai_trigger_payload = self._inputs and self._inputs.get( "crewai_trigger_payload"