diff --git a/tasks.py b/tasks.py index ed6022e..ff8d7de 100644 --- a/tasks.py +++ b/tasks.py @@ -644,9 +644,9 @@ def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, logger.info(f"{wxid}上次定时群成员定时添好友任务在2小时内,不再执行") return - time_difference_seconds = today_seconds_remaining() + cache_task_run_time_wxid_logs.append({"runTime":int(time.time())}) - await gewe_service.save_task_run_time_by_wxid_async(wxid,'scheduled_task_add_contacts_from_chatrooms',cache_task_run_time_wxid_logs,time_difference_seconds) + await gewe_service.save_task_run_time_by_wxid_async(wxid,'scheduled_task_add_contacts_from_chatrooms',cache_task_run_time_wxid_logs,3600*2)