diff --git a/src/cleveragents/agents/composite.py b/src/cleveragents/agents/composite.py index d11217173..b38d2e738 100644 --- a/src/cleveragents/agents/composite.py +++ b/src/cleveragents/agents/composite.py @@ -20,6 +20,7 @@ from ..langgraph.bridge import RxPyLangGraphBridge from ..reactive.stream_router import ReactiveStreamRouter from ..templates.renderer import TemplateRenderer from .base import Agent +import copy logger = logging.getLogger(__name__) @@ -168,7 +169,8 @@ class CompositeAgent(Agent): # pylint: disable=too-many-instance-attributes This method satisfies the abstract base class requirement. """ - return await self.process(message, context) + isolated_context = copy.deepcopy(context) + return await self.process(message, isolated_context) async def process( self, message: str, context: Optional[dict[str, Any]] = None