You've already forked RekomenciBackend
fix skills endpoints
This commit is contained in:
@@ -1,6 +1,7 @@
|
|||||||
from collections.abc import Sequence
|
from collections.abc import Sequence
|
||||||
|
|
||||||
from sqlalchemy import insert, select
|
from sqlalchemy import insert, select
|
||||||
|
from sqlalchemy.exc import IntegrityError
|
||||||
from sqlalchemy.ext.asyncio import AsyncSession
|
from sqlalchemy.ext.asyncio import AsyncSession
|
||||||
|
|
||||||
from template_project.adapters.data_gateways.tables import key_skills_table
|
from template_project.adapters.data_gateways.tables import key_skills_table
|
||||||
@@ -24,4 +25,7 @@ class KeySkillsDataGateway:
|
|||||||
insert_statement = insert(key_skills_table).values(
|
insert_statement = insert(key_skills_table).values(
|
||||||
[{"name": _} for _ in name]
|
[{"name": _} for _ in name]
|
||||||
)
|
)
|
||||||
|
try:
|
||||||
await self._session.execute(insert_statement)
|
await self._session.execute(insert_statement)
|
||||||
|
except IntegrityError:
|
||||||
|
pass
|
||||||
|
|||||||
@@ -38,5 +38,6 @@ async def add_key_skill(
|
|||||||
unit_of_work: FromDishka[UnitOfWork],
|
unit_of_work: FromDishka[UnitOfWork],
|
||||||
data_gateway: FromDishka[KeySkillsDataGateway],
|
data_gateway: FromDishka[KeySkillsDataGateway],
|
||||||
) -> None:
|
) -> None:
|
||||||
|
print(request.key_skills)
|
||||||
await data_gateway.add_skills(request.key_skills)
|
await data_gateway.add_skills(request.key_skills)
|
||||||
await unit_of_work.commit()
|
await unit_of_work.commit()
|
||||||
|
|||||||
Reference in New Issue
Block a user