27 lines
693 B
Python
27 lines
693 B
Python
import os
|
|
from apscheduler.schedulers.asyncio import AsyncIOScheduler
|
|
|
|
_scheduler = AsyncIOScheduler(timezone="UTC")
|
|
|
|
VK_HOUR = int(os.getenv("VK_IMPORT_HOUR", "6"))
|
|
VK_MINUTE = int(os.getenv("VK_IMPORT_MINUTE", "0"))
|
|
|
|
|
|
def start():
|
|
from vk_parser import run_import
|
|
_scheduler.add_job(
|
|
run_import,
|
|
trigger="cron",
|
|
hour=VK_HOUR,
|
|
minute=VK_MINUTE,
|
|
id="vk_daily_import",
|
|
replace_existing=True,
|
|
)
|
|
_scheduler.start()
|
|
print(f"[Scheduler] VK-импорт запланирован на {VK_HOUR:02d}:{VK_MINUTE:02d} UTC каждый день")
|
|
|
|
|
|
def shutdown():
|
|
if _scheduler.running:
|
|
_scheduler.shutdown(wait=False)
|