diff --git a/plugins/message_push_task/main.py b/plugins/message_push_task/main.py index 0ae35f8..fc3831a 100644 --- a/plugins/message_push_task/main.py +++ b/plugins/message_push_task/main.py @@ -47,7 +47,6 @@ class MessagePushTask(MessagePluginInterface): super().__init__() self.feature = self.register_feature() self.db = None - async_job.every_seconds(5)(self.process_scheduled_tasks) def initialize(self, context: Dict[str, Any]) -> bool: """初始化插件""" @@ -61,6 +60,7 @@ class MessagePushTask(MessagePluginInterface): # 初始化组件 self.db = TaskDBOperator(self.db_manager) + async_job.every_seconds(5)(self.process_scheduled_tasks) # 初始化数据库表 if not self.db.init_tables(): self.LOG.error("初始化数据库表失败")