dev
AlexP077 3 years ago committed by Dmitry Titov
parent d192e90780
commit 374c1f0047

@ -1,6 +1,7 @@
import os
from celery import Celery
from celery.schedules import crontab
from postamates.settings import CELERY_BROKER_URL
from postamates.settings import CELERY_NAMESPACE
@ -15,11 +16,11 @@ app.config_from_object('django.conf:settings', namespace=CELERY_NAMESPACE)
app.conf.beat_schedule = {
'age_day_every_24h': {
'task': 'service.tasks.add_age_day',
'schedule': 24 * 60 * 60.0,
'schedule': crontab(minute=0, hour=0),
},
'ml_func_every_24h': {
'task': 'service.tasks.raschet',
'schedule': 24 * 60 * 60.0,
'schedule': crontab(minute=0, hour=0),
},
}

@ -170,3 +170,4 @@ CELERY_NAMESPACE = 'CELERY'
PROJECT_NAME = 'postamates'
CACHE_TIMEOUT = 0
DEFAULT_PLACEMENT_POINT_UPDATE_RADIUS = 500
AGE_DAY_LIMIT = 270

@ -3,6 +3,7 @@ import time
from celery import shared_task
from django.db.models import F
from postamates.settings import AGE_DAY_LIMIT
from service.models import PlacementPoint
@ -23,7 +24,7 @@ def add_age_day():
qs = PlacementPoint.objects
c1 = qs.filter(sample_trn=True).count()
qs.update(age_day=F('age_day') + 1)
qs2 = qs.filter(age_day__gt=270)
qs2 = qs.filter(age_day__gt=AGE_DAY_LIMIT)
qs2.update(sample_trn=True)
c2 = PlacementPoint.objects.filter(sample_trn=True).count()
if c2 - c1 != 0:

Loading…
Cancel
Save