public/tubearchivist
1
0
Fork 0
mirror of https://git.vectorsigma.ru/public/tubearchivist.git synced 2026-08-08 07:19:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix version check not triggering

Browse Source
This commit is contained in:
Simon
2024-07-12 14:30:39 +02:00
parent 9b84169fab
commit 81bf614afa
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
tubearchivist/config/management/commands/ta_startup.py
View File

@@ -12,6 +12,7 @@ from django.conf import settings
from django.core.management.base import BaseCommand, CommandError from django.core.management.base import BaseCommand, CommandError
from django_celery_beat.models import CrontabSchedule from django_celery_beat.models import CrontabSchedule
from home.models import CustomPeriodicTask from home.models import CustomPeriodicTask
from home.tasks import version_check
from home.src.es.connect import ElasticWrap from home.src.es.connect import ElasticWrap
from home.src.es.index_setup import ElasitIndexWrap from home.src.es.index_setup import ElasitIndexWrap
from home.src.es.snapshot import ElasticSnapshot from home.src.es.snapshot import ElasticSnapshot
@@ -147,6 +148,14 @@ class Command(BaseCommand):
else: else:
self.stdout.write(self.style.SUCCESS(" no new update found")) self.stdout.write(self.style.SUCCESS(" no new update found"))
version_task = CustomPeriodicTask.objects.filter(name="version_check")
if not version_task.exists():
return
if not version_task.first().last_run_at:
self.style.SUCCESS(" ✓ send initial version check task")
version_check.delay()
def _mig_index_setup(self): def _mig_index_setup(self):
"""migration: validate index mappings""" """migration: validate index mappings"""
self.stdout.write("[MIGRATION] validate index mappings") self.stdout.write("[MIGRATION] validate index mappings")