celery执行ansible任务时提示 "not attribute _config"

执行任务时,在celery worker中显示的错误信息:

`AttributeError: 'Worker' object has no attribute '_config'``

解决办法:
在tasks.py 文件中, ansible任务的函数中,增加 以下参数。

from multiprocessing import current_process
@app.task
def run_playbooks(hosts,playbooks):
        current_process()._config = {'semprefix': '/mp'}  
        run = RunPlaybooks(hosts)
        res = run.run(playbooks=playbooks)
        return res

猜你喜欢

转载自blog.51cto.com/zhenfen/2105628