Record materialization outcome and duration for a single feature view.
(
feature_view_name: str, success: bool, duration_seconds: float
)
| 408 | |
| 409 | |
| 410 | def track_materialization( |
| 411 | feature_view_name: str, success: bool, duration_seconds: float |
| 412 | ): |
| 413 | """Record materialization outcome and duration for a single feature view.""" |
| 414 | if not _config.materialization: |
| 415 | return |
| 416 | status = "success" if success else "failure" |
| 417 | materialization_result_total.labels( |
| 418 | feature_view=feature_view_name, status=status |
| 419 | ).inc() |
| 420 | materialization_duration_seconds.labels(feature_view=feature_view_name).observe( |
| 421 | duration_seconds |
| 422 | ) |
| 423 | |
| 424 | |
| 425 | def emit_online_audit_log( |