diff --git a/src/python/PythonSDK/foundationallm/event_handlers/openai_assistant_async_event_handler.py b/src/python/PythonSDK/foundationallm/event_handlers/openai_assistant_async_event_handler.py
index 4dcf60968..7367e64bc 100644
--- a/src/python/PythonSDK/foundationallm/event_handlers/openai_assistant_async_event_handler.py
+++ b/src/python/PythonSDK/foundationallm/event_handlers/openai_assistant_async_event_handler.py
@@ -122,7 +122,7 @@ async def update_state_api_analysis_results_async(self):
             analysis_result = OpenAIAssistantsHelpers.parse_run_step(v)
             if analysis_result:
                 self.interim_result.analysis_results.append(analysis_result)
-        await self.operations_manager.set_operation_result(self.request.operation_id, self.request.instance_id, self.interim_result)
+        await self.operations_manager.set_operation_result_async(self.request.operation_id, self.request.instance_id, self.interim_result)
         
     async def update_state_api_content_async(self):
         self.interim_result.content = [] # Clear the content list before adding new messages.
@@ -130,4 +130,4 @@ async def update_state_api_content_async(self):
             content_items = OpenAIAssistantsHelpers.parse_message(v)
             self.interim_result.content.extend(content_items)
 
-        await self.operations_manager.set_operation_result(self.request.operation_id, self.request.instance_id, self.interim_result)
+        await self.operations_manager.set_operation_result_async(self.request.operation_id, self.request.instance_id, self.interim_result)