remove unused code

app.py

@@ -119,9 +119,8 @@ async def chat(query,history,audience,sources,reports):
     reports = []
     
     inputs = {"user_input": query,"audience": audience_prompt,"sources":sources}
-    result = agent.astream_events(inputs,version = "v1") #{"callbacks":[MyCustomAsyncHandler()]})
-    # result = rag_chain.stream(inputs)
-
+    result = agent.astream_events(inputs,version = "v1") 
+    
     # path_reformulation = "/logs/reformulation/final_output"
     # path_keywords = "/logs/keywords/final_output"
     # path_retriever = "/logs/find_documents/final_output"
@@ -187,84 +186,6 @@ async def chat(query,history,audience,sources,reports):
             
             yield history,docs_html,output_query,output_language,gallery #,output_query,output_keywords
  
-
-
-            # if event["event"] == "on_chat_model_stream" and event["name"] != "transform_query": # if streaming answer
-            #     if start_streaming == False:
-            #         start_streaming = True
-            #         # history[-1] = (query,"")
-            #         history.append(ChatMessage(role="assistant", content = ""))
-            #     if type(history[-1].metadata) != dict :
-            #         # print("metadata : ", history[-1].metadata)
-            #         # history.append(ChatMessage(role="assistant", content = ""))
-
-            #         last_message_content = history[-1].content
-            #         last_message_content += event["data"]["chunk"].content
-            #         last_message_content = parse_output_llm_with_sources(last_message_content)
-            #         history[-1] = ChatMessage(role="assistant", content = last_message_content)
-            #     # new_token = event["data"]["chunk"].content
-            #     # # time.sleep(0.01)
-            #     # previous_answer = history[-1][1]
-            #     # previous_answer = previous_answer if previous_answer is not None else ""
-            #     # answer_yet = previous_answer + new_token
-            #     # answer_yet = parse_output_llm_with_sources(answer_yet)
-            #     # history[-1] = (query,answer_yet)
-
-            
-            # elif event["name"] == "retrieve_documents" and event["event"] == "on_chain_end": # when documents are retrieved
-            #     try:
-            #         docs = event["data"]["output"]["documents"]
-            #         docs_html = []
-            #         for i, d in enumerate(docs, 1):
-            #             docs_html.append(make_html_source(d, i))
-            #         docs_html = "".join(docs_html)
-            #     except Exception as e:
-            #         print(f"Error getting documents: {e}")
-            #         print(event)
-
-            # # elif event["name"] == "retrieve_documents" and event["event"] == "on_chain_start":
-            # #     print(event)
-            # #     questions = event["data"]["input"]["questions"]
-            # #     questions = "\n".join([f"{i+1}. {q['question']} ({q['source']})" for i,q in enumerate(questions)])
-            # #     answer_yet = "🔄️ Searching in the knowledge base\n{questions}"
-            # #     history[-1] = (query,answer_yet)
-
-            # # TODO  append step de tool avec les questions qui sont utilisées pour la recherche
-            # for event_name,(event_description,display_output) in steps_display.items(): # display steps
-            #     if event["name"] == event_name:
-            #         if event["event"] == "on_chain_start":
-            #             # answer_yet = f"<p><span class='loader'></span>{event_description}</p>"
-            #             # answer_yet = make_toolbox(event_description, "", checked = False)
-            #             answer_yet = event_description
-            #             # answer_yet = ChatMessage(role="assistant", content = "processing", metadata={'title' :event_description})
-
-            #             history.append(ChatMessage(role="assistant", content = "", metadata={'title' :event_description}))
-            #             # history[-1] = (query,answer_yet)
-            #         # elif event["event"] == "on_chain_end":
-            #         #     answer_yet = ""
-            #         #     history[-1] = (query,answer_yet)
-            #             # if display_output:
-            #             #     print(event["data"]["output"])
-
-            # # if op['path'] == path_reformulation: # reforulated question
-            # #     try:
-            # #         output_language = op['value']["language"] # str
-            # #         output_query = op["value"]["question"]
-            # #     except Exception as e:
-            # #         raise gr.Error(f"ClimateQ&A Error: {e} - The error has been noted, try another question and if the error remains, you can contact us :)")
-            
-            # # if op["path"] == path_keywords:
-            # #     try:
-            # #         output_keywords = op['value']["keywords"] # str
-            # #         output_keywords = " AND ".join(output_keywords)
-            # #     except Exception as e:
-            # #         pass
-
-
-
-            # history = [tuple(x) for x in history]
-            # yield history,docs_html,output_query,output_language,gallery,output_query,output_keywords
-
     except Exception as e:
         print(event, "has failed")
         raise gr.Error(f"{e}")
@@ -327,23 +248,9 @@ async def chat(query,history,audience,sources,reports):
         history[-1] = (history[-1][0],answer_yet)
         history = [tuple(x) for x in history]
 
-    # gallery = [x.metadata["image_path"] for x in docs if (len(x.metadata["image_path"]) > 0 and "IAS" in x.metadata["image_path"])]
-    # if len(gallery) > 0:
-    #     gallery = list(set("|".join(gallery).split("|")))
-    #     gallery = [get_image_from_azure_blob_storage(x) for x in gallery]
-
     yield history,docs_html,output_query,output_language,gallery#,output_query,output_keywords
 
 
-
-#     else:
-#         docs_string = "No relevant passages found in the climate science reports (IPCC and IPBES)"
-#         complete_response = "**No relevant passages found in the climate science reports (IPCC and IPBES), you may want to ask a more specific question (specifying your question on climate issues).**"
-#         messages.append({"role": "assistant", "content": complete_response})
-#         gradio_format = make_pairs([a["content"] for a in messages[1:]])
-#         yield gradio_format, messages, docs_string
-
-
 def save_feedback(feed: str, user_id):
     if len(feed) > 1:
         timestamp = str(datetime.now().timestamp())
@@ -387,56 +294,6 @@ papers_cols_widths = {
 papers_cols = list(papers_cols_widths.keys())
 papers_cols_widths = list(papers_cols_widths.values())
 
-# async def find_papers(query, keywords,after):
-
-#     summary = ""
-    
-#     df_works = oa.search(keywords,after = after)
-#     df_works = df_works.dropna(subset=["abstract"])
-#     df_works = oa.rerank(query,df_works,reranker)
-#     df_works = df_works.sort_values("rerank_score",ascending=False)
-#     G = oa.make_network(df_works)
-
-#     height = "750px"
-#     network = oa.show_network(G,color_by = "rerank_score",notebook=False,height = height)
-#     network_html = network.generate_html()
-
-#     network_html = network_html.replace("'", "\"")
-#     css_to_inject = "<style>#mynetwork { border: none !important; } .card { border: none !important; }</style>"
-#     network_html = network_html + css_to_inject
-
-    
-#     network_html = f"""<iframe style="width: 100%; height: {height};margin:0 auto" name="result" allow="midi; geolocation; microphone; camera; 
-#     display-capture; encrypted-media;" sandbox="allow-modals allow-forms 
-#     allow-scripts allow-same-origin allow-popups 
-#     allow-top-navigation-by-user-activation allow-downloads" allowfullscreen="" 
-#     allowpaymentrequest="" frameborder="0" srcdoc='{network_html}'></iframe>"""
-
-
-#     docs = df_works["content"].head(15).tolist()
-
-#     df_works = df_works.reset_index(drop = True).reset_index().rename(columns = {"index":"doc"})
-#     df_works["doc"] = df_works["doc"] + 1
-#     df_works = df_works[papers_cols]
-
-#     yield df_works,network_html,summary
-
-#     chain = make_rag_papers_chain(llm)
-#     result = chain.astream_log({"question": query,"docs": docs,"language":"English"})
-#     path_answer = "/logs/StrOutputParser/streamed_output/-"
-
-#     async for op in result:
-
-#         op = op.ops[0]
-
-#         if op['path'] == path_answer: # reforulated question
-#             new_token = op['value'] # str
-#             summary += new_token
-#         else:
-#             continue
-#         yield df_works,network_html,summary
-    
-
 
 # --------------------------------------------------------------------
 # Gradio
@@ -467,15 +324,12 @@ def vote(data: gr.LikeData):
 
 
 with gr.Blocks(title="Climate Q&A", css_paths=os.getcwd()+ "/style.css", theme=theme,elem_id = "main-component") as demo:
-    # user_id_state = gr.State([user_id])
 
     with gr.Tab("ClimateQ&A"):
 
         with gr.Row(elem_id="chatbot-row"):
             with gr.Column(scale=2):
-                # state = gr.State([system_template])
                 chatbot = gr.Chatbot(
-                    # value=[(None,init_prompt)],
                     value = [ChatMessage(role="assistant", content=init_prompt)],
                     type = "messages",
                     show_copy_button=True,
@@ -483,7 +337,7 @@ with gr.Blocks(title="Climate Q&A", css_paths=os.getcwd()+ "/style.css", theme=t
                     elem_id="chatbot",
                     layout = "panel",
                     avatar_images = (None,"https://i.ibb.co/YNyd5W2/logo4.png"),
-                )#,avatar_images = ("assets/logo4.png",None))
+                )
                 
                 # bot.like(vote,None,None)
 
@@ -491,8 +345,7 @@ with gr.Blocks(title="Climate Q&A", css_paths=os.getcwd()+ "/style.css", theme=t
 
                 with gr.Row(elem_id = "input-message"):
                     textbox=gr.Textbox(placeholder="Ask me anything here!",show_label=False,scale=7,lines = 1,interactive = True,elem_id="input-textbox")
-                    # submit = gr.Button("",elem_id = "submit-button",scale = 1,interactive = True,icon = "https://static-00.iconduck.com/assets.00/settings-icon-2048x2046-cw28eevx.png")
-
+                 
 
             with gr.Column(scale=1, variant="panel",elem_id = "right-panel"):
 
@@ -630,8 +483,6 @@ with gr.Blocks(title="Climate Q&A", css_paths=os.getcwd()+ "/style.css", theme=t
 
     dropdown_samples.change(change_sample_questions,dropdown_samples,samples)
 
-    # query_papers.submit(generate_keywords,[query_papers], [keywords_papers])
-    # search_papers.click(find_papers,[query_papers,keywords_papers,after], [papers_dataframe,citations_network,papers_summary])
 
     demo.queue()