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