Skip to content

Commit 67ab1e6

Browse files
committed
Updated skipped files Prometheus endpoint to use new Pydantic model and to group skipped file information by source
1 parent 95c4b18 commit 67ab1e6

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

src/murfey/server/api/prometheus.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
from murfey.server.murfey_db import murfey_db
1313
from murfey.util import sanitise
1414
from murfey.util.db import RsyncInstance
15-
from murfey.util.models import RsyncerInfo
15+
from murfey.util.models import RsyncerInfo, RsyncerSkippedFiles
1616

1717
logger = getLogger("murfey.server.api.prometheus")
1818

@@ -90,13 +90,13 @@ def increment_rsync_transferred_files_prometheus(
9090
).inc(rsyncer_info.data_bytes)
9191

9292

93-
@router.post(
94-
"/visits/{visit_name}/increment_rsync_skipped_files_prometheus/{increment_count}"
95-
)
93+
@router.post("/visits/{visit_name}/increment_rsync_skipped_files_prometheus")
9694
def increment_rsync_skipped_files_prometheus(
97-
visit_name: str, increment_count: int, db=murfey_db
95+
visit_name: str, rsyncer_skipped_files: RsyncerSkippedFiles, db=murfey_db
9896
):
99-
prom.skipped_files.labels(visit=visit_name).inc(increment_count)
97+
prom.skipped_files.labels(
98+
rsync_source=rsyncer_skipped_files.source, visit=visit_name
99+
).inc(rsyncer_skipped_files.increment_count)
100100

101101

102102
@router.post("/visits/{visit_name}/monitoring/{on}")

0 commit comments

Comments
 (0)