-
Notifications
You must be signed in to change notification settings - Fork 4
/
Copy pathcelery_app.py
26 lines (20 loc) · 1.13 KB
/
celery_app.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
import logging
import os
from celery import Celery
from wannadb_web.worker.tasks import BaseTask, DocumentBaseAddAttributes, DocumentBaseConfirmNugget, DocumentBaseForgetMatches, DocumentBaseForgetMatchesForAttribute, DocumentBaseGetOrderedNuggets, DocumentBaseInteractiveTablePopulation, DocumentBaseLoad, DocumentBaseRemoveAttributes, DocumentBaseUpdateAttributes, TestTask, InitManager, CreateDocumentBase
logging.basicConfig(level=logging.DEBUG, format="%(asctime)s - %(name)s - %(levelname)s - %(message)s")
app = Celery(__name__)
app.conf.broker_url = os.environ.get("CELERY_BROKER_URL")
app.register_task(BaseTask)
app.register_task(TestTask)
app.register_task(InitManager)
app.register_task(CreateDocumentBase)
app.register_task(DocumentBaseLoad)
app.register_task(DocumentBaseAddAttributes)
app.register_task(DocumentBaseUpdateAttributes)
app.register_task(DocumentBaseRemoveAttributes)
app.register_task(DocumentBaseForgetMatches)
app.register_task(DocumentBaseForgetMatchesForAttribute)
app.register_task(DocumentBaseInteractiveTablePopulation)
app.register_task(DocumentBaseGetOrderedNuggets)
app.register_task(DocumentBaseConfirmNugget)