@@ -54,11 +54,7 @@ class MchDataCenter(object):
except Exception as ex:
print(ex)
finally:
- for i in range(60):
- if self._mquit:
- break
- else:
- stime.sleep(1)
+ stime.sleep(1)
def del_redis(self, redis, name,latest_time):
for item in redis.hscan_iter(name):
@@ -71,7 +67,6 @@ class MchDataCenter(object):
time = int(time)
if latest_time <= time:
fdel = False
-
if fdel:
redis.hdel(name, key)
pass