almet/argos
1
0
Fork 0
mirror of https://framagit.org/framasoft/framaspace/argos.git synced 2025-04-28 18:02:41 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

🔀 Merge branch 'fix-23' into 'main'

Browse source 
⚡ — Use background tasks for alerting (fix #23)

Closes #23

See merge request framasoft/framaspace/argos!38
This commit is contained in:
Luc Didry 2024-03-27 15:19:21 +00:00
commit a4324b3747
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
argos/server/routes/api.py
View file

@ -1,7 +1,7 @@
"""Web interface for machines""" """Web interface for machines"""
from typing import List, Union from typing import List, Union
from fastapi import APIRouter, Depends, Request from fastapi import APIRouter, BackgroundTasks, Depends, Request
from sqlalchemy.orm import Session from sqlalchemy.orm import Session
from argos.logging import logger from argos.logging import logger
@ -30,6 +30,7 @@ async def read_tasks(
async def create_results( async def create_results(
request: Request, request: Request,
results: List[AgentResult], results: List[AgentResult],
background_tasks: BackgroundTasks,
db: Session = Depends(get_db), db: Session = Depends(get_db),
config: Config = Depends(get_config), config: Config = Depends(get_config),
agent_id: Union[None, str] = None, agent_id: Union[None, str] = None,
@ -59,8 +60,9 @@ async def create_results(
# Don’t create an alert if the severity has not changed # Don’t create an alert if the severity has not changed
if last_severity != severity: if last_severity != severity:
# XXX Use a job queue or make it async background_tasks.add_task(
handle_alert(config, result, task, severity, last_severity, request) handle_alert, config, result, task, severity, last_severity, request
)
db_results.append(result) db_results.append(result)
db.commit() db.commit()