porridger/back/scheduler.py

15 lines
400 B
Python

from . import add_poems_and_filters
from rocketry import Rocketry
from rocketry.conds import daily
import datetime
from .db import async_session
app = Rocketry(execution="async")
# Create task:
@app.task('minutely')
async def daily_check():
# Фильтруем по сроку годности
await add_poems_and_filters.check_obsolete(async_session, current_date=datetime.date.today())