Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 0 additions & 4 deletions examples/EmergencyManagement/Server/controllers_emergency.py
Original file line number Diff line number Diff line change
@@ -1,13 +1,9 @@
import asyncio
from dataclasses import asdict
from reticulum_openapi.controller import Controller, handle_exceptions
from examples.EmergencyManagement.Server.database import async_session
from examples.EmergencyManagement.Server.models_emergency import (
EmergencyActionMessage,
Event,
EAMStatus,
Detail,
Point,
)


Expand Down
1 change: 1 addition & 0 deletions examples/EmergencyManagement/Server/database.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
engine = create_async_engine(DATABASE_URL, echo=False)
async_session = async_sessionmaker(engine, expire_on_commit=False, class_=AsyncSession)


async def init_db():
async with engine.begin() as conn:
await conn.run_sync(Base.metadata.create_all)
2 changes: 1 addition & 1 deletion examples/EmergencyManagement/Server/models_emergency.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
from dataclasses import dataclass
from reticulum_openapi.model import BaseModel
from sqlalchemy.orm import declarative_base
from sqlalchemy import Column, Integer, String, Float, JSON
from sqlalchemy import Column, Integer, String, JSON

Base = declarative_base()

Expand Down
3 changes: 3 additions & 0 deletions tests/test_persistence.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,17 +8,20 @@

Base = declarative_base()


class ItemORM(Base):
__tablename__ = "items"
id = Column(Integer, primary_key=True)
name = Column(String)


@dataclass
class Item(BaseModel):
id: int
name: str
__orm_model__ = ItemORM


@pytest.mark.asyncio
async def test_crud_roundtrip():
engine = create_async_engine("sqlite+aiosqlite:///:memory:")
Expand Down
Loading