14 lines
313 B
Python
14 lines
313 B
Python
from celery import Celery
|
|
from analysis import log_analyzer as la
|
|
|
|
app = Celery('tasks', backend='redis://redis', broker='redis://redis')
|
|
|
|
|
|
@app.task
|
|
def add(x, y):
|
|
return x + y
|
|
|
|
@app.task
|
|
def analyze(config, log_ids):
|
|
settings = la.parse_settings(config)
|
|
store = la.run_analysis(log_ids, settings, la.LOADERS) |