Преглед изворни кода

feat: 解构任务先过滤掉leve=3的视频

jihuaqiang пре 3 месеци
родитељ
комит
781a64bcc9
1 измењених фајлова са 1 додато и 0 уклоњено
  1. 1 0
      scheduler/odps_fetch.py

+ 1 - 0
scheduler/odps_fetch.py

@@ -46,6 +46,7 @@ def fetch_priority_posts(limit: int = 10, offset: int = 0, dt: Optional[str] = N
             level, reason, count, extend, dt
         FROM {ODPS_TABLE}
         WHERE dt = '{target_dt}'
+          AND level IN (0, 1, 2)
         ORDER BY level ASC
         LIMIT {offset}, {limit}
     """