diff --git a/tasks.py b/tasks.py index 7213fd9..5282b8b 100644 --- a/tasks.py +++ b/tasks.py @@ -4,7 +4,7 @@ import time,datetime from celery import Celery import celery.schedules from redbeat import RedBeatSchedulerEntry -from datetime import timedelta +#from datetime import timedelta from services.redis_service import RedisService from services.kafka_service import KafkaService @@ -204,7 +204,7 @@ def scheduled_task_sync_wx_info(self, redis_config, kafka_config, gewe_config): def scheduled_task_add_contacts_from_chatrooms_p(self, redis_config, kafka_config, gewe_config): async def task(): try: - now = datetime.datetime.now() + now = datetime.now() if now.hour < 8: logger.info(f"定时群成员定时添好友任务不启动,当前时间为 {now.strftime('%Y-%m-%d %H:%M:%S')},早于8点") return @@ -358,7 +358,7 @@ def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, ''' async def task(): try: - now = datetime.datetime.now() + now = datetime.now() if now.hour < 8: logger.info(f"定时群成员定时添好友任务不启动,当前时间为 {now.strftime('%Y-%m-%d %H:%M:%S')},早于8点") return