zhangbo 1 year ago
parent
commit
56a27ece10
1 changed files with 2 additions and 2 deletions
  1. 2 2
      alg_recsys_recall_undertake.py

+ 2 - 2
alg_recsys_recall_undertake.py

@@ -46,8 +46,8 @@ def main():
         read_key = "recall:item:score:region:h:{}:data66:rule66:{}:{}".format(code, date, hour)
         keys.append(read_key)
         write_key = "recall:item:score:region:h:{}:data66:rule66:{}:{}".format(code, date_next, hour_next)
-    value = redis_helper.get_data_from_set(set(keys))
-    print(str(value))
+        value = redis_helper.get_data_from_set(read_key)
+        print(str(value))
 
     # records_process_for_list(result, process_and_store, max_size=50, num_workers=8)
     log_.info("完成执行:" + datetime.now().strftime("%Y-%m-%d %H:%M:%S"))