update

recommend.py

@@ -232,12 +232,16 @@ def video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type, al
         #     t.append(gevent.spawn(pool_recall.get_return_video_reall))
     elif flow_pool_abtest_group == 'experimental_flow_set_level':
         t = [gevent.spawn(pool_recall.rov_pool_recall_with_region, size, expire_time),
-             gevent.spawn(pool_recall.flow_pool_recall_new_with_level, size, config_.QUICK_FLOW_POOL_ID, flow_pool_abtest_group),
-             gevent.spawn(pool_recall.flow_pool_recall_new_with_level, size, flow_pool_abtest_group)]
+             gevent.spawn(pool_recall.flow_pool_recall_new_with_level,
+                          size, flow_pool_id=config_.QUICK_FLOW_POOL_ID, flow_pool_abtest_group=flow_pool_abtest_group),
+             gevent.spawn(pool_recall.flow_pool_recall_new_with_level,
+                          size, flow_pool_abtest_group=flow_pool_abtest_group)]
     else:
         t = [gevent.spawn(pool_recall.rov_pool_recall_with_region, size, expire_time),
-             gevent.spawn(pool_recall.flow_pool_recall, size, config_.QUICK_FLOW_POOL_ID, flow_pool_abtest_group),
-             gevent.spawn(pool_recall.flow_pool_recall, size, flow_pool_abtest_group)]
+             gevent.spawn(pool_recall.flow_pool_recall,
+                          size, flow_pool_id=config_.QUICK_FLOW_POOL_ID, flow_pool_abtest_group=flow_pool_abtest_group),
+             gevent.spawn(pool_recall.flow_pool_recall,
+                          size, flow_pool_abtest_group=flow_pool_abtest_group)]
     if ab_code == 60058:
         t.append(gevent.spawn(pool_recall.get_U2I_reall, mid))
         t.append(gevent.spawn(pool_recall.get_play_reall, mid))
@@ -467,12 +471,16 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
         #     t.append(gevent.spawn(pool_recall.get_return_video_reall, 'rv2:'))
     elif flow_pool_abtest_group == 'experimental_flow_set_level':
         t = [gevent.spawn(pool_recall.rov_pool_recall_with_region, size, expire_time),
-             gevent.spawn(pool_recall.flow_pool_recall_new_with_level, size, config_.QUICK_FLOW_POOL_ID, flow_pool_abtest_group),
-             gevent.spawn(pool_recall.flow_pool_recall_new_with_level, size, flow_pool_abtest_group)]
+             gevent.spawn(pool_recall.flow_pool_recall_new_with_level,
+                          size, flow_pool_id=config_.QUICK_FLOW_POOL_ID, flow_pool_abtest_group=flow_pool_abtest_group),
+             gevent.spawn(pool_recall.flow_pool_recall_new_with_level,
+                          size, flow_pool_abtest_group=flow_pool_abtest_group)]
     else:
         t = [gevent.spawn(pool_recall.rov_pool_recall_with_region, size, expire_time),
-             gevent.spawn(pool_recall.flow_pool_recall, size, config_.QUICK_FLOW_POOL_ID, flow_pool_abtest_group),
-             gevent.spawn(pool_recall.flow_pool_recall, size, flow_pool_abtest_group)]
+             gevent.spawn(pool_recall.flow_pool_recall,
+                          size, flow_pool_id=config_.QUICK_FLOW_POOL_ID, flow_pool_abtest_group=flow_pool_abtest_group),
+             gevent.spawn(pool_recall.flow_pool_recall,
+                          size, flow_pool_abtest_group=flow_pool_abtest_group)]
     if ab_code == 60054 or ab_code == 60066 or ab_code == 60072 or ab_code == 60073 or ab_code == 60074:
         t.append(gevent.spawn(pool_recall.get_sim_hot_item_reall_filter))
     elif ab_code == 60056 or ab_code == 60071: