gardel/lightrag
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Clean up logging output and remove redundant log messages

Browse Source
This commit is contained in:
yangdx
2025-02-27 20:17:28 +08:00
parent 05cf029bcc
commit 05d03638ec
3 changed files with 6 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
gunicorn_config.py
View File

@@ -61,9 +61,7 @@ def on_starting(server):
except ImportError: except ImportError:
print("psutil not installed, skipping memory usage reporting") print("psutil not installed, skipping memory usage reporting")
print("=" * 80)
print("Gunicorn initialization complete, forking workers...") print("Gunicorn initialization complete, forking workers...")
print("=" * 80)
def on_exit(server): def on_exit(server):

6
lightrag/kg/networkx_impl.py
View File

@@ -92,8 +92,6 @@ class NetworkXStorage(BaseGraphStorage):
logger.info( logger.info(
f"Loaded graph from {self._graphml_xml_file} with {preloaded_graph.number_of_nodes()} nodes, {preloaded_graph.number_of_edges()} edges" f"Loaded graph from {self._graphml_xml_file} with {preloaded_graph.number_of_nodes()} nodes, {preloaded_graph.number_of_edges()} edges"
) )
else:
logger.info("Created new empty graph")
else: else:
preloaded_graph = NetworkXStorage.load_nx_graph(self._graphml_xml_file) preloaded_graph = NetworkXStorage.load_nx_graph(self._graphml_xml_file)
self._graph = preloaded_graph or nx.Graph() self._graph = preloaded_graph or nx.Graph()
@@ -101,8 +99,8 @@ class NetworkXStorage(BaseGraphStorage):
logger.info( logger.info(
f"Loaded graph from {self._graphml_xml_file} with {preloaded_graph.number_of_nodes()} nodes, {preloaded_graph.number_of_edges()} edges" f"Loaded graph from {self._graphml_xml_file} with {preloaded_graph.number_of_nodes()} nodes, {preloaded_graph.number_of_edges()} edges"
) )
else:
logger.info("Created new empty graph") logger.info("Created new empty graph")
self._node_embed_algorithms = { self._node_embed_algorithms = {
"node2vec": self._node2vec_embed, "node2vec": self._node2vec_embed,

8
lightrag/kg/shared_storage.py
View File

@@ -107,9 +107,9 @@ def try_initialize_namespace(namespace: str) -> bool:
if namespace not in _init_flags: if namespace not in _init_flags:
_init_flags[namespace] = True _init_flags[namespace] = True
direct_log(f"Process {os.getpid()} ready to initialize namespace {namespace}") direct_log(f"Process {os.getpid()} ready to initialize storage namespace: [{namespace}]")
return True return True
direct_log(f"Process {os.getpid()} namespace {namespace} already to initialized") direct_log(f"Process {os.getpid()} storage namespace already to initialized: [{namespace}]")
return False return False
@@ -146,7 +146,7 @@ def get_namespace_object(namespace: str) -> Any:
else: else:
_share_objects[namespace] = None _share_objects[namespace] = None
direct_log( direct_log(
f"Created namespace({namespace}): type={type(_share_objects[namespace])}, pid={os.getpid()}" f"Created namespace: {namespace}(type={type(_share_objects[namespace])})"
) )
return _share_objects[namespace] return _share_objects[namespace]
@@ -169,7 +169,7 @@ def get_namespace_data(namespace: str) -> Dict[str, Any]:
else: else:
_shared_dicts[namespace] = {} _shared_dicts[namespace] = {}
direct_log( direct_log(
f"Created namespace({namespace}): type={type(_shared_dicts[namespace])}, pid={os.getpid()}" f"Created namespace: {{namespace}}({type(_shared_dicts[namespace])}) "
) )
return _shared_dicts[namespace] return _shared_dicts[namespace]