diff --git a/lightrag/operate.py b/lightrag/operate.py index 022ad17e..35126fa2 100644 --- a/lightrag/operate.py +++ b/lightrag/operate.py @@ -3011,7 +3011,7 @@ async def _get_node_data( ): # get similar entities logger.info( - f"Query nodes: {query}, top_k: {query_param.top_k}, cosine: {entities_vdb.cosine_better_than_threshold}" + f"Query nodes: {query} (top_k:{query_param.top_k}, cosine:{entities_vdb.cosine_better_than_threshold})" ) results = await entities_vdb.query(query, top_k=query_param.top_k) @@ -3287,7 +3287,7 @@ async def _get_edge_data( query_param: QueryParam, ): logger.info( - f"Query edges: {keywords}, top_k: {query_param.top_k}, cosine: {relationships_vdb.cosine_better_than_threshold}" + f"Query edges: {keywords} (top_k:{query_param.top_k}, cosine:{relationships_vdb.cosine_better_than_threshold})" ) results = await relationships_vdb.query(keywords, top_k=query_param.top_k) diff --git a/lightrag/utils.py b/lightrag/utils.py index f7675664..0a5234ce 100644 --- a/lightrag/utils.py +++ b/lightrag/utils.py @@ -707,7 +707,7 @@ def priority_limit_async_func_call( timeout_info.append(f"Health Check: {max_task_duration}s") timeout_str = ( - f" (Timeouts: {', '.join(timeout_info)})" if timeout_info else "" + f"(Timeouts: {', '.join(timeout_info)})" if timeout_info else "" ) logger.info( f"{queue_name}: {workers_needed} new workers initialized {timeout_str}"