def publish_user_input()

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

• 19 lines of code
• 7 McCabe index (conditional complexity)

def publish_user_input(user_input_json):
    backend_url = 'http://rag-interface-service:8701/webpublish'
    number_of_check_counter = number_of_check
    try:
        response = requests.post(backend_url, json=user_input_json)
        if response.status_code == 200:
            #st.success(response.json()['message'])
            request_id = response.json()['request_id']
            # Check for processed results periodically
            for _ in range(number_of_check):  
                number_of_check_counter -= 1
                if number_of_check_counter == 0:
                    st.error('Timeout! Failed to get query response. Please try again later.')
                    break
                if check_processed_result(request_id, user_input_json):
                    break
                time.sleep(CHECK_INTERVAL_SEC)

        else:
            st.error('Failed to publish user input to the backend')
    except requests.RequestException as e:
        st.error(f'Request failed: {e}')