all

alg_recsys_rank_item_realtime_1day.py

@@ -175,7 +175,7 @@ def h_timer_check():
         log_.info("video的数据量:{}".format(len(video_list)))
         records_process_for_list(video_list, process_and_store, max_size=50, num_workers=8)
 
-        redis_helper.set_data_to_redis(REDIS_PREFIX + "partiton", partition, 24 * 3600)
+        redis_helper.set_data_to_redis(REDIS_PREFIX + "partition", partition, 24 * 3600)
 
 
 

alg_recsys_rank_item_realtime_1h.py

@@ -155,7 +155,7 @@ def h_timer_check():
         log_.info("video的数据量:{}".format(len(video_list)))
         records_process_for_list(video_list, process_and_store, max_size=50, num_workers=8)
 
-        redis_helper.set_data_to_redis(REDIS_PREFIX + "partiton", partition, 24 * 3600)
+        redis_helper.set_data_to_redis(REDIS_PREFIX + "partition", partition, 24 * 3600)