File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1010from sqlmodel import select
1111
1212import murfey .server .api .websocket as ws
13+ import murfey .server .prometheus as prom
1314from murfey .server import _transport_object
1415from murfey .server .api import templates
1516from murfey .server .api .auth import (
@@ -186,6 +187,11 @@ def create_session(
186187 db .add (s )
187188 db .commit ()
188189 sid = s .id
190+ alert_end_time = prom .alert_end_time ._value .get () # timestamp
191+ if visit_end_time .end_time :
192+ visit_end_timestamp = visit_end_time .end_time .timestamp ()
193+ if alert_end_time < visit_end_timestamp :
194+ prom .alert_end_time .set (visit_end_timestamp )
189195 return sid
190196
191197
@@ -300,7 +306,7 @@ def get_silences(instrument_name: MurfeyInstrumentName):
300306 response = requests .get (f"{ alertmanager_url } /api/v2/silences?{ query_params } " )
301307 if response .status_code != 200 :
302308 logger .warning (
303- f"Tried to get silences for { sanitise (instrument_name )} , but received status { response .status_code } from alertmanager API"
309+ f"Get silences for { sanitise (instrument_name )} received status { response .status_code } from alertmanager API"
304310 )
305311 active_silences = []
306312 for silence in response .json ():
Original file line number Diff line number Diff line change 4343 "Whether the corresponding visit should be monitored or not" ,
4444 ["visit" ],
4545)
46+
47+ alert_end_time = Gauge ("alert_end_time" , "End time for alerts" , [])
You can’t perform that action at this time.
0 commit comments