From 09a01f94a9554e77ae0616b9ce066b1780ff5fb6 Mon Sep 17 00:00:00 2001 From: H Vs Date: Mon, 7 Apr 2025 17:42:01 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tasks.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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