def check_processed_result()

in sample_app/cerebral_genai/code/rag-on-edge-web/page_vector_search.py [0:0]

• 14 lines of code
• 5 McCabe index (conditional complexity)

def check_processed_result(request_id, user_input_json):
    check_url = f'http://rag-interface-service:8701/check_processed_result/{request_id}'
    response = requests.get(check_url)
    
    if response.status_code == 200:
        result_data = response.json()
        if result_data['status'] == 'success':
            #st.write(f"test-before: {st.session_state.conversation_history}")
            #query_response_str = query_response.replace('SEARCH_QUERY_HERE',user_input_json['user_query']).replace('SEARCH_ANSWER_HERE',result_data['processed_result'])
            query_response_str = result_data['processed_result']
            # Display assistant response in chat message container
            with col1.chat_message("assistant"):
                col1.write(query_response_str)
            # Add assistant response to chat history
            st.session_state.conversation_history.append({"role": "assistant", "content": query_response_str})

            #st.text(st.session_state.conversation_history[-1])
            #st.write(f"test-after: {st.session_state.conversation_history}")
            # keep the conversation history to a certain number
            if len(st.session_state.conversation_history)> CONV_HISTORY_NUM:
                st.session_state.conversation_history.pop(0) #removing old history

            
            # col1.title("Conversation Log")
            # for item in st.session_state.conversation_history:
            #     col1.success(item)
            
            return True
    
    return False