Add celery beat for topic import

diff --git a/.gitignore b/.gitignore
index 57dae518b35a73c9a5452ddd42c9c57822d3b935..2d4a60d3948968e584f51400df4dad09cc13c48c 100644 (file)
--- a/.gitignore
+++ b/.gitignore
@@ -7,6 +7,7 @@ log.txt
 *.rdb
 uploads
 thumbnails
+celerybeat-schedule
 
 # Created by https://www.gitignore.io/api/linux,macos,python,windows
 

diff --git a/app/tasks/__init__.py b/app/tasks/__init__.py
index 05da6e2a1ec304bb63d8f0d92793d5b0342f6f26..8fa75aae6234fb2a5b36b3c69ac8a5e14c56f297 100644 (file)
--- a/app/tasks/__init__.py
+++ b/app/tasks/__init__.py
@@ -18,6 +18,7 @@
 import flask
 from flask.ext.sqlalchemy import SQLAlchemy
 from celery import Celery
+from celery.schedules import crontab
 from app import app
 from app.models import *
 
@@ -64,4 +65,12 @@ def make_celery(app):
 
 celery = make_celery(app)
 
+CELERYBEAT_SCHEDULE = {
+       'topic_list_import': {
+               'task': 'app.tasks.forumtasks.importTopicList',
+               'schedule': crontab(minute=1, hour=1),
+       }
+}
+celery.conf.beat_schedule = CELERYBEAT_SCHEDULE
+
 from . import importtasks, forumtasks, emails

diff --git a/app/tasks/forumtasks.py b/app/tasks/forumtasks.py
index 338ffa28a3954c3f42dc19c2d5091b57fe498bf1..dc8be7f7756eae8f422c38e7ba1fe554c282861d 100644 (file)
--- a/app/tasks/forumtasks.py
+++ b/app/tasks/forumtasks.py
@@ -138,4 +138,7 @@ def importTopicList():
                topic.views      = info["views"]
                topic.created_at = info["date"]
 
+       for p in Package.query.all():
+               p.recalcScore()
+
        db.session.commit()