@@ -957,8 +957,9 @@ async def get_events(request: Request):
957957# -----------------------------------------------------------------------------
958958# Telemetry of pipeline execution and other events(not node stuff).
959959# This is a separate collection from
960- # EventHistory since it may have a much higher volume and different query patterns,
961- # and we want to be able to optimize indexes and storage separately.
960+ # EventHistory since it may have a much higher volume and different
961+ # query patterns and allows us to optimize indexes and storage
962+ # separately.
962963
963964@app .post ('/telemetry' , response_model = dict , tags = ["telemetry" ])
964965async def post_telemetry (
@@ -1024,7 +1025,7 @@ async def get_telemetry(request: Request):
10241025 if val not in ['true' , 'false' ]:
10251026 raise HTTPException (
10261027 status_code = status .HTTP_400_BAD_REQUEST ,
1027- detail = "Invalid value for is_infra_error, must be 'true' or 'false'" ,
1028+ detail = "Bad is_infra_error value, use 'true' or 'false'" ,
10281029 )
10291030 if val == 'true' :
10301031 query_params ['is_infra_error' ] = True
@@ -1050,11 +1051,11 @@ async def get_telemetry(request: Request):
10501051async def get_telemetry_stats (request : Request ):
10511052 """Get aggregated telemetry statistics.
10521053
1053- This is rule-based anomaly detection using
1054+ This is rule-based anomaly detection using
10541055 thresholded empirical rates computed over
10551056 a sliding (rolling) time window.
1056- This is not a full anomaly detection system
1057- with baselines or machine learning, but at
1057+ This is not a full anomaly detection system
1058+ with baselines or machine learning, but at
10581059 last something to start with.
10591060
10601061 Query parameters:
0 commit comments