wrap sync call to asyncio.thread
This commit is contained in:
+2
-1
@@ -1,6 +1,7 @@
|
|||||||
from fastapi import APIRouter
|
from fastapi import APIRouter
|
||||||
import aiofiles
|
import aiofiles
|
||||||
import json
|
import json
|
||||||
|
import asyncio
|
||||||
from async_lru import alru_cache
|
from async_lru import alru_cache
|
||||||
|
|
||||||
router = APIRouter(prefix='/api/v1', tags=['tariffs'])
|
router = APIRouter(prefix='/api/v1', tags=['tariffs'])
|
||||||
@@ -9,7 +10,7 @@ router = APIRouter(prefix='/api/v1', tags=['tariffs'])
|
|||||||
async def get_tariffs():
|
async def get_tariffs():
|
||||||
async with aiofiles.open('data/tariffs.json', 'r', encoding='utf-8') as f:
|
async with aiofiles.open('data/tariffs.json', 'r', encoding='utf-8') as f:
|
||||||
content = await f.read()
|
content = await f.read()
|
||||||
return json.loads(content)
|
return await asyncio.to_thread(json.loads(content))
|
||||||
|
|
||||||
@router.get('/tariffs')
|
@router.get('/tariffs')
|
||||||
async def get_tariffs():
|
async def get_tariffs():
|
||||||
|
|||||||
Reference in New Issue
Block a user