Commit 086f306c authored by litaolemo's avatar litaolemo

update

parent ddc8b80a
...@@ -139,8 +139,7 @@ kwargs_dict = { ...@@ -139,8 +139,7 @@ kwargs_dict = {
def get_task_from_redis(): def get_task_from_redis():
while True: while True:
try: try:
import pdb
pdb.set_trace()
print('----------------------') print('----------------------')
# now = datetime.datetime.now() # now = datetime.datetime.now()
# if now.hour >= exit_hour: # if now.hour >= exit_hour:
...@@ -182,6 +181,8 @@ def single_thead(processe,name): ...@@ -182,6 +181,8 @@ def single_thead(processe,name):
allow = 10 allow = 10
data_list = [] data_list = []
while True: while True:
import pdb
pdb.set_trace()
now = datetime.datetime.now() now = datetime.datetime.now()
# if now.hour >= exit_hour: # if now.hour >= exit_hour:
# sys.exit() # sys.exit()
......
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