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)