@@ -150,7 +150,8 @@ def initMsgFunc(request):
thread_kwargs = {
'user_id': userID,
'distribute_key': distribute_key,
- 'expire': expire
+ 'expire': expire,
+ 'end_time': end_time
}
del_push_info_thread = threading.Thread(
target=distribute_cloud_storage_coupons,
