update days

eda/smart_rank/tag3_update_user_portrait_offline.py

@@ -277,7 +277,7 @@ def update_tag3_user_portrait(cl_id):
 
 
 def consume_kafka():
-    sql = "select distinct cl_id from kafka_tag3_log where log_time > UNIX_TIMESTAMP(DATE_SUB(NOW(), INTERVAL 30 day))"
+    sql = "select distinct cl_id from kafka_tag3_log where log_time > UNIX_TIMESTAMP(DATE_SUB(NOW(), INTERVAL 60 day))"
     db, cursor = get_doris_prod()
     cursor.execute(sql)
     device_ids_lst = [i[0] for i in cursor.fetchall()]