Commit 9b772f83 authored by 李小芳's avatar 李小芳

Merge branch 'change_time_outdate' into 'master'

add

See merge request !37
parents 652ca1b4 e8714d49
...@@ -366,7 +366,7 @@ def judge_offset_partition_have_consum(card_info=None, offset=0, partition=0): ...@@ -366,7 +366,7 @@ def judge_offset_partition_have_consum(card_info=None, offset=0, partition=0):
create_time = card_info['create_time'] create_time = card_info['create_time']
datetime_create_time = datetime.datetime.strptime(create_time, '%Y-%m-%d %H:%M:%S') datetime_create_time = datetime.datetime.strptime(create_time, '%Y-%m-%d %H:%M:%S')
str_data = str(datetime_create_time.year) + str(datetime_create_time.month) + str(datetime_create_time.day) str_data = str(datetime_create_time.year) + str(datetime_create_time.month) + str(datetime_create_time.day)
if str_data in ['20191229', '20191230', '20191228']: if str_data in ['20191229', '20191230', '20191228', '20191227']:
return False return False
redis_list_data = 0 redis_list_data = 0
......
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