(global_config,reasoning_path,if_findings=False)
| 104 | return entity_descriptions |
| 105 | |
| 106 | def get_aggregation_description(global_config,reasoning_path,if_findings=False): |
| 107 | |
| 108 | aggregation_results=[] |
| 109 | |
| 110 | communities=set([community for each_path in reasoning_path for community in each_path]) |
| 111 | for community in communities: |
| 112 | temp=search_community(community,global_config['working_dir']) |
| 113 | if temp=="": |
| 114 | continue |
| 115 | aggregation_results.append(temp) |
| 116 | if if_findings: |
| 117 | columns=['entity_name','entity_description','findings'] |
| 118 | aggregation_descriptions="\t\t".join(columns)+"\n" |
| 119 | aggregation_descriptions+="\n".join([information[0]+"\t\t"+str(information[1])+"\t\t"+information[2] for information in aggregation_results]) |
| 120 | else: |
| 121 | columns=['entity_name','entity_description'] |
| 122 | aggregation_descriptions="\t\t".join(columns)+"\n" |
| 123 | aggregation_descriptions+="\n".join([information[0]+"\t\t"+str(information[1]) for information in aggregation_results]) |
| 124 | return aggregation_descriptions,communities |
| 125 | def query_graph(global_config,db,query): |
| 126 | use_llm_func: callable = global_config["use_llm_func"] |
| 127 | embedding: callable=global_config["embeddings_func"] |
no test coverage detected