sarlink/sarlink-portal-api
7
0
Fork 0
mirror of https://github.com/i701/sarlink-portal-api.git synced 2025-07-13 09:55:49 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat(tasks): add periodic task to remove old jobs with enhanced logging and context handling ✨

Browse Source
This commit is contained in:
i701
2025-07-09 20:13:20 +05:00
parent 35384ef049
commit ff897ee2ab
1 changed files with 18 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
api/tasks.py
View File

@ -10,6 +10,7 @@ from django.utils import timezone
from api.omada import Omada from api.omada import Omada
from apibase.env import env, BASE_DIR from apibase.env import env, BASE_DIR
from procrastinate.contrib.django import app from procrastinate.contrib.django import app
from procrastinate import builtin_tasks
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@ -17,6 +18,23 @@ logger = logging.getLogger(__name__)
env.read_env(os.path.join(BASE_DIR, ".env")) env.read_env(os.path.join(BASE_DIR, ".env"))
@app.periodic(cron="0 4 * * *")
@app.task(
queueing_lock="remove_old_jobs",
pass_context=True,
)
async def remove_old_jobs(context, timestamp):
logger.info("Running remove_old_jobs task...")
return await builtin_tasks.remove_old_jobs(
context,
queue="heavy_tasks",
max_hours=24,
remove_failed=True,
remove_cancelled=True,
remove_aborted=True,
)
@app.task @app.task
def add(x, y): def add(x, y):
logger.info(f"Executing test background task with {x} and {y}") logger.info(f"Executing test background task with {x} and {y}")