Commit 21d8b249 authored by litaolemo's avatar litaolemo

update

parent d180d7af
......@@ -162,6 +162,7 @@ def get_task_from_redis():
rds_1.incr(platform_str)
yield platform
rds_1.decr(platform_str)
except Exception as e:
print(e)
......@@ -275,6 +276,9 @@ if __name__ == "__main__":
futures.append(future)
print('Processe %s start' % processe)
executor.shutdown(True)
for future in futures:
print(future)
# while True:
# now = datetime.datetime.now()
# if now.hour >= exit_hour:
......
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