all

alg_recsys_recall_tags_videosv2.py

@@ -124,8 +124,16 @@ def get_video_tags_v2():
     PROJECT = "loghubods"
     TABLE = "loghubods.automated_updates_category_labels_1"
     try:
-        sql = '''select videoid,secondary_labels
-from loghubods.automated_updates_category_labels_1'''
+        sql = '''SELECT  videoid
+        ,secondary_labels
+FROM    loghubods.automated_updates_category_labels_1
+WHERE   (
+            dt LIKE '2023%'
+            OR      dt LIKE '2024%'
+            OR      dt LIKE '2025%'
+            OR      dt LIKE '2026%'
+)
+'''
         print("sql:" + sql)
         records = execute_sql_from_odps(project=PROJECT, sql=sql)
         video_tags_list = []