Commit 69c39698 authored by litaolemo's avatar litaolemo

update

parent 21d8b249
......@@ -159,6 +159,7 @@ def get_task_from_redis():
if process_num:
if res.get(platform):
if int(res.get(platform)) > int(process_num):
print("get platfrom %s" % platform)
rds_1.incr(platform_str)
yield platform
rds_1.decr(platform_str)
......
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