JZTXT

Celery 使用 Ansible API 返回 None

发布时间 2023-07-06 14:18:26作者: snake_j
# 在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(
    ...
)