Add celery beat for topic import

3 files changed, 13 insertions, 0 deletions

diff --git a/.gitignore b/.gitignore
index 57dae51..2d4a60d 100644
--- 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 05da6e2..8fa75aa 100644
--- 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 338ffa2..dc8be7f 100644
--- 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()