Skip to content

Commit f0bcd43

Browse files
[AINODE] Fix logger level filter (apache#16195)
1 parent 0dc583e commit f0bcd43

File tree

2 files changed

+13
-6
lines changed

2 files changed

+13
-6
lines changed

iotdb-core/ainode/ainode/core/constant.py

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -73,12 +73,6 @@
7373
# AINode log
7474
LOG_FILE_TYPE = ["all", "info", "warning", "error"]
7575
AINODE_LOG_FILE_NAME_PREFIX = "log_ainode_"
76-
AINODE_LOG_FILE_NAMES = [
77-
"log_ainode_all.log",
78-
"log_ainode_info.log",
79-
"log_ainode_warning.log",
80-
"log_ainode_error.log",
81-
]
8276
AINODE_LOG_FILE_LEVELS = [logging.DEBUG, logging.INFO, logging.WARNING, logging.ERROR]
8377
DEFAULT_LOG_LEVEL = logging.INFO
8478
INFERENCE_LOG_FILE_NAME_PREFIX_TEMPLATE = (

iotdb-core/ainode/ainode/core/log.py

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,9 @@ def __init__(self, log_file_name_prefix: str, log_dir=AINODE_LOG_DIR):
8585
interval=1,
8686
encoding="utf-8",
8787
)
88+
if LOG_FILE_TYPE[i] != "all":
89+
file_handler.setLevel(logging.NOTSET)
90+
file_handler.addFilter(LogLevelFilter(file_level))
8891

8992
# set renamer
9093
def universal_namer(
@@ -145,3 +148,13 @@ class Logger(BaseLogger):
145148

146149
def __init__(self, log_file_name_prefix: str = AINODE_LOG_FILE_NAME_PREFIX):
147150
super().__init__(log_file_name_prefix=log_file_name_prefix)
151+
152+
153+
class LogLevelFilter(logging.Filter):
154+
155+
def __init__(self, level: int):
156+
super().__init__()
157+
self.level = level
158+
159+
def filter(self, record: logging.LogRecord) -> bool:
160+
return record.levelno == self.level

0 commit comments

Comments
 (0)