Multiprocessing in FastAPI

@app.post("/async-endpoint")
async def test_endpoint():
    try:
        loop = asyncio.get_running_loop()
        with concurrent.futures.ProcessPoolExecutor(max_workers=1) as pool:
            results = await loop.run_in_executor(pool,
                                                 subject_extract_check_process,
                                                  *(args, subject_check_rules, docx_paras, pdf_paras))  # wait result
    except Exception as err:
        logger.error(f"Subprocess execute fail: {str(err)}")
        results = []
    return results