FilesExpand file tree

 master

/

tasks.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

23 lines (18 loc) · 656 Bytes

 master

/

tasks.py

Copy path

Top

File metadata and controls

• Code
• Blame

23 lines (18 loc) · 656 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

from celery import Celery

from celery.schedules import crontab

from webapp import create_app

from webapp.news.parsers import habr

flask_app = create_app()

celery_app = Celery('tasks', broker='redis://localhost:6379/0')

@celery_app.task

def habr_snippets():

with flask_app.app_context():

habr.get_news_snippets()

@celery_app.task

def habr_content():

with flask_app.app_context():

habr.get_news_content()

@celery_app.on_after_configure.connect

def setup_periodic_tasks(sender, **kwargs):

sender.add_periodic_task(crontab(minute='*/1'), habr_snippets.s())

sender.add_periodic_task(crontab(minute='*/2'), habr_content.s())