Skip to content

Commit 4463430

Browse files
committed
added utest
1 parent cf9fc55 commit 4463430

File tree

2 files changed

+31
-1
lines changed

2 files changed

+31
-1
lines changed

nodescraper/models/event.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ class Event(BaseModel):
5050
timestamp: datetime.datetime = Field(
5151
default_factory=lambda: datetime.datetime.now(datetime.timezone.utc)
5252
)
53-
reporter: str = "ERROR_SCRAPER"
53+
reporter: str = "NODE_SCRAPER"
5454
category: str
5555
description: str
5656
data: dict = Field(default_factory=dict)

test/unit/plugin/test_dmesg_analyzer.py

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -204,3 +204,33 @@ def test_page_fault(system_info):
204204
for event in res.events:
205205
assert event.priority == EventPriority.ERROR
206206
assert event.description == "amdgpu Page Fault"
207+
208+
209+
def test_lnet_and_lustre_boot_errors_are_warning_events(system_info):
210+
dmesg_log = "\n".join(
211+
[
212+
"[ 548.063411] LNetError: 2719:0:(o2iblnd.c:3327:kiblnd_startup()) ko2iblnd: No matching interfaces",
213+
"[ 548.073737] LNetError: 105-4: Error -100 starting up LNI o2ib",
214+
"[Wed Jun 25 17:19:52 2025] LustreError: 2719:0:(events.c:639:ptlrpc_init_portals()) network initialisation failed",
215+
]
216+
)
217+
218+
analyzer = DmesgAnalyzer(
219+
system_info=system_info,
220+
)
221+
data = DmesgData(dmesg_content=dmesg_log)
222+
result = analyzer.analyze_data(data, DmesgAnalyzerArgs())
223+
224+
by_msg = {e.description: e for e in result.events}
225+
226+
m1 = "LNet: ko2iblnd has no matching interfaces"
227+
m2 = "LNet: Error starting up LNI"
228+
m3 = "Lustre: network initialisation failed"
229+
230+
assert m1 in by_msg, f"Missing event: {m1}"
231+
assert m2 in by_msg, f"Missing event: {m2}"
232+
assert m3 in by_msg, f"Missing event: {m3}"
233+
234+
for m in (m1, m2, m3):
235+
ev = by_msg[m]
236+
assert ev.priority == EventPriority.WARNING, f"{m} should be WARNING"

0 commit comments

Comments
 (0)