# 在celery task 中 加入
# from multiprocessing import current_process
# current_process()._config={"semprefix":"/mp"}
@app.task
def create_task()
from multiprocessing import current_process
current_process()._config={"semprefix":"/mp"}
# ...do something...
return "hello world"
create_task.apply_async(
...
)
Celery 使用 Ansible API 返回 None
发布时间 2023-07-06 14:18:26作者: snake_j