from celery import Celery
import subprocess, yaml, os


app = Celery('Autom8RedisTaskq', broker='redis://localhost:16379/0', backend="redis://localhost:16379/0")


@app.task
def setup_redis(cpaneluser, cpanelhome, option):
    subprocess.call(' /opt/Autom8Redis/autom8redis_wrapper.py '+cpaneluser+' '+cpanelhome+' '+option, shell=True)