SILVER/NODEDC_MISSION_CORE
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

feat(lab): canonize versioned report template

Browse Source
This commit is contained in:
DCCONSTRUCTIONS
2026-07-27 16:05:32 +03:00
parent 2c016b117d
commit 95c6540691
20 changed files with 582 additions and 128 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/k1link/web/advanced_laboratory_api.py
+19
View File
@@ -224,6 +224,11 @@ def _project_e33(
"linked E32 binding",
)
profile = _object(identity.get("profile"), "E33 profile")
profile_acceptance = _object(
profile.get("acceptance"),
"E33 profile acceptance",
)
deadlines = _object(profile.get("deadlines"), "E33 deadlines")
worker = _object(identity.get("worker"), "E33 worker")
metrics = _object(result.report.get("metrics"), "E33 metrics")
accounting = _object(metrics.get("accounting"), "E33 accounting")
@@ -232,6 +237,8 @@ def _project_e33(
result_age = _object(metrics.get("result_age_ms"), "E33 result age")
resources = _object(metrics.get("resources"), "E33 resources")
process_rss = _object(resources.get("process_rss_mib"), "E33 RSS")
linked_metrics = _object(linked_e32.report.get("metrics"), "linked E32 metrics")
linked_frames = _object(linked_metrics.get("frames"), "linked E32 frames")
gpu_utilization = _object(
resources.get("gpu_utilization_percent"),
"E33 GPU utilization",
@@ -254,15 +261,27 @@ def _project_e33(
},
"metrics": {
"source_frames": accounting.get("source_frames"),
"source_available_frames": linked_frames.get("source_available"),
"source_unavailable_frames": (
int(accounting["source_frames"])
- int(linked_frames["source_available"])
),
"delivered_frames": accounting.get("delivered"),
"input_superseded": accounting.get("input_superseded"),
"result_superseded": accounting.get("result_superseded"),
"effective_delivery_fps": metrics.get("effective_delivery_fps"),
"source_span_seconds": metrics.get("source_span_seconds"),
"deadline_miss_fraction": metrics.get("deadline_miss_fraction"),
"processing_p95_ms": processing.get("p95"),
"release_lag_p95_ms": release_lag.get("p95"),
"result_age_p95_ms": result_age.get("p95"),
"result_age_max_ms": result_age.get("maximum"),
"result_deadline_ms": deadlines.get("result_ms"),
"process_rss_p95_mib": process_rss.get("p95"),
"process_rss_max_mib": process_rss.get("maximum"),
"process_rss_limit_mib": profile_acceptance.get(
"maximum_process_rss_mib"
),
"gpu_utilization_p95_percent": gpu_utilization.get("p95"),
"gpu_visible": resources.get("gpu_visible"),
"work_queue_capacity": work_queue.get("capacity"),