File tree 1 file changed +23
-0
lines changed
1 file changed +23
-0
lines changed Original file line number Diff line number Diff line change 1
1
import logging
2
2
import time
3
3
from fnmatch import fnmatch
4
+ from logging import Filter
4
5
from pathlib import Path
5
6
6
7
import chromadb
11
12
from .document import Document
12
13
from .document_processor import DocumentProcessor
13
14
15
+
16
+ class ChromaDBFilter (Filter ):
17
+ """Filter out expected ChromaDB warnings about existing IDs."""
18
+
19
+ def filter (self , record : logging .LogRecord ) -> bool :
20
+ if record .levelno == logging .WARNING :
21
+ # Filter out specific ChromaDB warnings about existing IDs
22
+ if record .name .startswith ("chromadb.segment.impl" ):
23
+ msg = record .getMessage ()
24
+ if "existing embedding ID" in msg :
25
+ return False
26
+ return True
27
+
28
+
29
+ # Add filter to ChromaDB loggers
30
+ for logger_name in [
31
+ "chromadb.segment.impl.metadata.sqlite" ,
32
+ "chromadb.segment.impl.vector.local_persistent_hnsw" ,
33
+ ]:
34
+ logging .getLogger (logger_name ).addFilter (ChromaDBFilter ())
35
+
36
+
14
37
logger = logging .getLogger (__name__ )
15
38
16
39
You can’t perform that action at this time.
0 commit comments