jihuaqiang пре 4 дана
родитељ
комит
f7a9f6769a
2 измењених фајлова са 7 додато и 2 уклоњено
  1. 0 1
      scheduler/decode_dispatch_job.py
  2. 7 1
      scheduler/decode_hourly_stats_job.py

+ 0 - 1
scheduler/decode_dispatch_job.py

@@ -490,7 +490,6 @@ def run_decode_dispatch_job() -> None:
             logger.info("无可发起的新批次候选数据 dt={} need={}", dt, need)
             logger.info("无可发起的新批次候选数据 dt={} need={}", dt, need)
             logger.info("解码调度任务结束(无新增任务)")
             logger.info("解码调度任务结束(无新增任务)")
             return
             return
-        logger.info("解码提交接口执行开始 records={}", records)
         posts = _build_posts_payload(records)
         posts = _build_posts_payload(records)
         logger.info("解码提交接口执行开始 posts={}", posts)
         logger.info("解码提交接口执行开始 posts={}", posts)
         ok, err_msg, body = _submit_decode(posts)
         ok, err_msg, body = _submit_decode(posts)

+ 7 - 1
scheduler/decode_hourly_stats_job.py

@@ -140,7 +140,13 @@ def _build_feishu_card(
     )
     )
     level_tag = "异常告警" if is_alert else "运行正常"
     level_tag = "异常告警" if is_alert else "运行正常"
     template = "red" if is_alert else "blue"
     template = "red" if is_alert else "blue"
-    status_line = "⚠️ 当前失败率已超过阈值,请尽快排查" if is_alert else "✅ 当前任务运行正常"
+    if is_alert:
+        if fail_rate > _ALERT_FAIL_RATE:
+            status_line = "⚠️ 当前失败率已超过阈值,请尽快排查"
+        else:
+            status_line = "⚠️ 当前成功率偏低且存在超时任务,请尽快排查"
+    else:
+        status_line = "✅ 当前任务运行正常"
 
 
     markdown_lines = [
     markdown_lines = [
         status_line,
         status_line,