fixed tasks log

This commit is contained in:
Ultradesu
2025-07-20 22:55:07 +03:00
parent dc6d170f08
commit ec869b2974
2 changed files with 6 additions and 9 deletions

View File

@@ -12,7 +12,7 @@ app = Celery('mysite')
app.conf.beat_schedule = { app.conf.beat_schedule = {
'periodical_servers_sync': { 'periodical_servers_sync': {
'task': 'sync_all_servers', 'task': 'sync_all_servers',
'schedule': crontab(minute='*'), 'schedule': crontab(minute=0, hour='*/3'), # Every 3 hours
}, },
'cleanup_old_task_logs': { 'cleanup_old_task_logs': {
'task': 'cleanup_task_logs', 'task': 'cleanup_task_logs',

View File

@@ -497,7 +497,9 @@ try:
IntervalSchedule, IntervalSchedule,
SolarSchedule SolarSchedule
) )
from django.contrib.auth.models import Group
# Unregister celery models that we don't want in admin
admin.site.unregister(GroupResult) admin.site.unregister(GroupResult)
admin.site.unregister(PeriodicTask) admin.site.unregister(PeriodicTask)
admin.site.unregister(ClockedSchedule) admin.site.unregister(ClockedSchedule)
@@ -506,13 +508,15 @@ try:
admin.site.unregister(SolarSchedule) admin.site.unregister(SolarSchedule)
admin.site.unregister(TaskResult) admin.site.unregister(TaskResult)
# Unregister Django's default Group model
admin.site.unregister(Group)
except (ImportError, admin.sites.NotRegistered): except (ImportError, admin.sites.NotRegistered):
pass pass
# Custom Celery admin interfaces # Custom Celery admin interfaces
try: try:
from django_celery_results.models import TaskResult from django_celery_results.models import TaskResult
from django_celery_beat.models import PeriodicTask
@admin.register(TaskResult) @admin.register(TaskResult)
class CustomTaskResultAdmin(admin.ModelAdmin): class CustomTaskResultAdmin(admin.ModelAdmin):
@@ -605,12 +609,5 @@ try:
def has_change_permission(self, request, obj=None): def has_change_permission(self, request, obj=None):
return False return False
@admin.register(PeriodicTask)
class CustomPeriodicTaskAdmin(admin.ModelAdmin):
list_display = ('name', 'task', 'enabled', 'last_run_at', 'total_run_count')
list_filter = ('enabled', 'last_run_at')
search_fields = ('name', 'task')
readonly_fields = ('last_run_at', 'total_run_count')
except ImportError: except ImportError:
pass pass