Commit d0a69db2 authored by 张彦钊's avatar 张彦钊

update dairyQueueUpdate file

parent 5c0ec458
...@@ -228,8 +228,7 @@ def pipe_line(queue_name, queue_arg, device_id): ...@@ -228,8 +228,7 @@ def pipe_line(queue_name, queue_arg, device_id):
def user_update(device_id,city_id,data_set_cid): def user_update(device_id,city_id,data_set_cid):
global native_queue_list global native_queue_list
#TODO 测试成功后把下面的list还原 #TODO 测试成功后把下面的list还原
# queue_name_list = ["native_queue","nearby_queue","nation_queue","megacity_queue"] queue_name_list = ["native_queue","nearby_queue","nation_queue","megacity_queue"]
queue_name_list = ["native_queue"]
for queue_name in queue_name_list: for queue_name in queue_name_list:
queue_list = get_queue(device_id, city_id,queue_name) queue_list = get_queue(device_id, city_id,queue_name)
if queue_name == "native_queue": if queue_name == "native_queue":
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment