# -*- coding: utf-8 -*-
# @File: scheduler.py
# @Date: 2025/5/12 16:17
# @Software: PyCharm
# @Author: xingc
# @Desc:
from datetime import datetime, timedelta

from apscheduler.schedulers.asyncio import AsyncIOScheduler
from apscheduler.triggers.date import DateTrigger

scheduler = AsyncIOScheduler()


def add_task(func, *args, task_id: str = None, **kwargs):
    scheduler.add_job(
        func,
        args=args,
        kwargs=kwargs,
        trigger=DateTrigger(run_date=(datetime.now() + timedelta(seconds=1))),
        id=task_id
    )