We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent df3ddd4 commit 5caccf8Copy full SHA for 5caccf8
run.py
@@ -2,8 +2,31 @@
2
from db import db
3
from models import article, source
4
import routes
5
+import feed
6
+from threading import Thread
7
+import time
8
9
with app.app_context():
10
db.create_all()
11
12
+def update_loop():
13
+ while True:
14
+ with app.app_context():
15
+ query = source.Source.query
16
+ for src in query.all():
17
+ try:
18
+ update_source(src)
19
+ except:
20
+ continue
21
+ time.sleep(60 * 15)
22
+
23
+def update_source(src):
24
+ parsed = feed.parse(src.feed)
25
+ feed_articles = feed.get_articles(parsed)
26
+ article.Article.insert_from_feed(src.id, feed_articles)
27
+ print('Updated ' + src.feed)
28
29
+thread = Thread(target=update_loop)
30
+thread.start()
31
32
app.run()
0 commit comments