mirror of
https://github.com/inventree/InvenTree
synced 2024-08-30 18:33:04 +00:00
Automatically delete old heartbeat messages
This commit is contained in:
parent
de85d61451
commit
f6dd710d6e
@ -8,6 +8,7 @@ import logging
|
|||||||
|
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
|
|
||||||
|
from django_q.models import Success
|
||||||
from django.core.exceptions import AppRegistryNotReady
|
from django.core.exceptions import AppRegistryNotReady
|
||||||
from django.db.utils import OperationalError, ProgrammingError
|
from django.db.utils import OperationalError, ProgrammingError
|
||||||
|
|
||||||
@ -48,9 +49,19 @@ def heartbeat():
|
|||||||
so we can determine that the background worker
|
so we can determine that the background worker
|
||||||
is actually running.
|
is actually running.
|
||||||
|
|
||||||
(There is probably a less "hacky" way of achieving this)
|
(There is probably a less "hacky" way of achieving this)?
|
||||||
"""
|
"""
|
||||||
pass
|
|
||||||
|
threshold = datetime.now() - timedelta(minutes=30)
|
||||||
|
|
||||||
|
# Delete heartbeat results more than half an hour old,
|
||||||
|
# otherwise they just create extra noise
|
||||||
|
heartbeats = Success.objects.filter(
|
||||||
|
func='InvenTree.tasks.heartbeat',
|
||||||
|
started__lte=threshold
|
||||||
|
)
|
||||||
|
|
||||||
|
heartbeats.delete()
|
||||||
|
|
||||||
|
|
||||||
def delete_successful_tasks():
|
def delete_successful_tasks():
|
||||||
|
Loading…
Reference in New Issue
Block a user