fabric_funtion.py

@parallel
def install():
    cmd = "celery -A test_celery worker --app=test_celery.celeryapp:app --concurrency=10 --loglevel=debug"
    run("apt-get install dtach && apt-get install -y python-pip && pip install celery && pip install requests && pip install pymongo")
    with settings(warn_only=True):
        runResult = run("mkdir -p /root/code/test_celery")
        if runResult.return_code == 1:
            print 'file exists'
        put("./test_celery/celeryapp.py", "/root/code/test_celery")
        put("./test_celery/run_tasks.py", "/root/code/test_celery")
        put("./test_celery/tasks.py", "/root/code/test_celery")
        put("./test_celery/ua.txt", "/root/code/test_celery")
        put("./test_celery/__init__.py", "/root/code/test_celery")
        with cd("/root/code"):
            result = run("ls -l")
            run('dtach -n `mktemp -u /tmp/%s.XXXX` %s' % ('dtach', cmd))
    return result