Bedrock Claude Error: roles must alternate – Works Locally with Ollama

[artist-genai]

I am trying to get this workflow to run but getting this error.
I can read and see what the issue is but have no idea as to how I can prevent this. This works fine with some other issues if ran with a local ollama model. But with Bedrock Claude I am not able to get this to work.

Any ideas as to how I can fix this?

DEBUG:anthropic._base_client:Request options: {'method': 'post', 'url': '/model/apac.anthropic.claude-3-haiku-20240307-v1:0/invoke', 'timeout': Timeout(connect=5.0, read=600, write=600, pool=600), 'files': None, 'json_data': {'max_tokens': 4096, 'messages': [{'role': 'user', 'content': 'Provide me an analysis for finances'}, {'role': 'user', 'content': "I'll provide an analysis for finances. To do this properly, I need to request the data for each of these data points from the Manager.\n\n@Manager need data for TRADES\n\n@Manager need data for CASH\n\n@Manager need data for DEBT"}], 'system': '\n You are part of an agentic workflow.\nYou will be working primarily as a Data Source for the other members of your team. There are tools specifically developed and provided. Use them to provide the required data to the team.\n\n<TEAM>\nYour team consists of agents Consultant and RelationshipManager\nConsultant will summarize and provide observations for any data point that the user will be asking for.\nRelationshipManager will triangulate these observations.\n</TEAM>\n\n<YOUR TASK>\nYou are advised to provide the team with the required data that is asked by the user. The Consultant may ask for more data which you are bound to provide.\n</YOUR TASK>\n\n<DATA POINTS>\nThere are 8 tools provided to you. They will resolve to these 8 data points:\n- TRADES.\n- DEBT as in Debt.\n- CASH.\n</DATA POINTS>\n\n<INSTRUCTIONS>\n- You will not be doing any analysis on the data.\n- You will not create any synthetic data. If any asked data point is not available as function. You will reply with "This data does not exist. TERMINATE"\n- You will not write any form of Code.\n- You will not help the Consultant in any manner other than providing the data.\n- You will provide data from functions if asked by RelationshipManager.\n</INSTRUCTIONS>', 'temperature': 0.5, 'tools': [{'name': 'df_trades', 'input_schema': {'properties': {}, 'required': [], 'type': 'object'}, 'description': '\n    Use this tool if asked for TRADES Data.\n\n    Returns: A JSON String containing the TRADES data.\n    '}, {'name': 'df_cash', 'input_schema': {'properties': {}, 'required': [], 'type': 'object'}, 'description': '\n    Use this tool if asked for CASH data.\n\n    Returns: A JSON String containing the CASH data.\n    '}, {'name': 'df_debt', 'input_schema': {'properties': {}, 'required': [], 'type': 'object'}, 'description': '\n    Use this tool if the asked for DEBT data.\n\n    Returns: A JSON String containing the DEBT data.\n    '}], 'anthropic_version': 'bedrock-2023-05-31'}}

ValueError: Unhandled message in agent container: <class 'autogen_agentchat.teams._group_chat._events.GroupChatError'>
INFO:autogen_core.events:{"payload": "{\"error\":{\"error_type\":\"BadRequestError\",\"error_message\":\"Error code: 400 - {'message': 'messages: roles must alternate between \\\"user\\\" and \\\"assistant\\\", but found multiple \\\"user\\\" roles in a row'}\",\"traceback\":\"Traceback (most recent call last):\\n\\n  File \\\"d:\\\\docs\\\\agents\\\\agent\\\\Lib\\\\site-packages\\\\autogen_agentchat\\\\teams\\\\_group_chat\\\\_chat_agent_container.py\\\", line 79, in handle_request\\n    async for msg in self._agent.on_messages_stream(self._message_buffer, ctx.cancellation_token):\\n\\n  File \\\"d:\\\\docs\\\\agents\\\\agent\\\\Lib\\\\site-packages\\\\autogen_agentchat\\\\agents\\\\_assistant_agent.py\\\", line 827, in on_messages_stream\\n    async for inference_output in self._call_llm(\\n\\n  File \\\"d:\\\\docs\\\\agents\\\\agent\\\\Lib\\\\site-packages\\\\autogen_agentchat\\\\agents\\\\_assistant_agent.py\\\", line 955, in _call_llm\\n    model_result = await model_client.create(\\n                   ^^^^^^^^^^^^^^^^^^^^^^^^^^\\n\\n  File \\\"d:\\\\docs\\\\agents\\\\agent\\\\Lib\\\\site-packages\\\\autogen_ext\\\\models\\\\anthropic\\\\_anthropic_client.py\\\", line 592, in create\\n    result: Message = cast(Message, await future)  # type: ignore\\n                                    ^^^^^^^^^^^^\\n\\n  File \\\"d:\\\\docs\\\\agents\\\\agent\\\\Lib\\\\site-packages\\\\anthropic\\\\resources\\\\messages\\\\messages.py\\\", line 2165, in create\\n    return await self._post(\\n           ^^^^^^^^^^^^^^^^^\\n\\n  File \\\"d:\\\\docs\\\\agents\\\\agent\\\\Lib\\\\site-packages\\\\anthropic\\\\_base_client.py\\\", line 1920, in post\\n    return await self.request(cast_to, opts, stream=stream, stream_cls=stream_cls)\\n           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\\n\\n  File \\\"d:\\\\docs\\\\agents\\\\agent\\\\Lib\\\\site-packages\\\\anthropic\\\\_base_client.py\\\", line 1614, in request\\n    return await self._request(\\n           ^^^^^^^^^^^^^^^^^^^^\\n\\n  File \\\"d:\\\\docs\\\\agents\\\\agent\\\\Lib\\\\site-packages\\\\anthropic\\\\_base_client.py\\\", line 1715, in _request\\n    raise self._make_status_error_from_response(err.response) from None\\n\\nanthropic.BadRequestError: Error code: 400 - {'message': 'messages: roles must alternate between \\\"user\\\" and \\\"assistant\\\", but found multiple \\\"user\\\" roles in a row'}\\n\"}}", "handling_agent": "RelationshipManager_7a22b73e-fb5f-48b5-ab06-f0e39711e2ab/7a22b73e-fb5f-48b5-ab06-f0e39711e2ab", "exception": "Unhandled message in agent container: <class 'autogen_agentchat.teams._group_chat._events.GroupChatError'>", "type": "MessageHandlerException"}
INFO:autogen_core:Publishing message of type GroupChatTermination to all subscribers: {'message': StopMessage(source='SelectorGroupChatManager', models_usage=None, metadata={}, content='An error occurred in the group chat.', type='StopMessage'), 'error': SerializableException(error_type='BadRequestError', error_message='Error code: 400 - {\'message\': \'messages: roles must alternate between "user" and "assistant", but found multiple "user" roles in a row\'}', traceback='Traceback (most recent call last):\n\n  File "d:\\docs\\agents\\agent\\Lib\\site-packages\\autogen_agentchat\\teams\\_group_chat\\_chat_agent_container.py", line 79, in handle_request\n    async for msg in self._agent.on_messages_stream(self._message_buffer, ctx.cancellation_token):\n\n  File "d:\\docs\\agents\\agent\\Lib\\site-packages\\autogen_agentchat\\agents\\_assistant_agent.py", line 827, in on_messages_stream\n    async for inference_output in self._call_llm(\n\n  File "d:\\docs\\agents\\agent\\Lib\\site-packages\\autogen_agentchat\\agents\\_assistant_agent.py", line 955, in _call_llm\n    model_result = await model_client.create(\n                   ^^^^^^^^^^^^^^^^^^^^^^^^^^\n\n  File "d:\\docs\\agents\\agent\\Lib\\site-packages\\autogen_ext\\models\\anthropic\\_anthropic_client.py", line 592, in create\n    result: Message = cast(Message, await future)  # type: ignore\n                                    ^^^^^^^^^^^^\n\n  File "d:\\docs\\agents\\agent\\Lib\\site-packages\\anthropic\\resources\\messages\\messages.py", line 2165, in create\n    return await self._post(\n           ^^^^^^^^^^^^^^^^^\n\n  File "d:\\docs\\agents\\agent\\Lib\\site-packages\\anthropic\\_base_client.py", line 1920, in post\n    return await self.request(cast_to, opts, stream=stream, stream_cls=stream_cls)\n           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n\n  File "d:\\docs\\agents\\agent\\Lib\\site-packages\\anthropic\\_base_client.py", line 1614, in request\n    return await self._request(\n           ^^^^^^^^^^^^^^^^^^^^\n\n  File "d:\\docs\\agents\\agent\\Lib\\site-packages\\anthropic\\_base_client.py", line 1715, in _request\n    raise self._make_status_error_from_response(err.response) from None\n\nanthropic.BadRequestError: Error code: 400 - {\'message\': \'messages: roles must alternate between "user" and "assistant", but found multiple "user" roles in a row\'}\n')}
INFO:autogen_core.events:{"payload": "Message could not be serialized", "sender": "SelectorGroupChatManager_7a22b73e-fb5f-48b5-ab06-f0e39711e2ab/7a22b73e-fb5f-48b5-ab06-f0e39711e2ab", "receiver": "output_topic_7a22b73e-fb5f-48b5-ab06-f0e39711e2ab/7a22b73e-fb5f-48b5-ab06-f0e39711e2ab", "kind": "MessageKind.PUBLISH", "delivery_stage": "DeliveryStage.SEND", "type": "Message"}