refactor(db): migrate database operations to async/await

- Replace SQLModel sync engine/session with SQLAlchemy async equivalents
- Update all CRUD operations and API endpoints to use async database calls
- Add asyncpg and python-dateutil dependencies
- Modify lifespan event to await database initialization

api/routers/chats.py

@@ -2,7 +2,7 @@ import uuid
 from typing import List
 
 from fastapi import APIRouter, Depends, HTTPException, status
-from sqlmodel import Session
+from sqlalchemy.ext.asyncio import AsyncSession
 
 # --- LangChain Imports ---
 from langchain_core.messages import BaseMessage, HumanMessage, AIMessage, ToolMessage
@@ -21,11 +21,11 @@ from workflow.title_generator import generate_chat_title
 router = APIRouter()
 
 # --- Helper Functions ---
-def get_chat_for_user(chat_id: uuid.UUID, user_id: uuid.UUID, db: Session) -> Chat:
+async def get_chat_for_user(chat_id: uuid.UUID, user_id: uuid.UUID, db: AsyncSession) -> Chat:
     """
     A helper dependency to get a chat and verify the current user owns it.
     """
-    chat = chat_crud.get_chat_by_id(db, chat_id)
+    chat = await chat_crud.get_chat_by_id(db, chat_id)
     if not chat:
         raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Chat not found")
     if chat.user_id != user_id:
@@ -56,19 +56,19 @@ def _convert_db_messages_to_langchain(db_messages: List[DBMessage]) -> List[Base
 # --- Chat CRUD Routes ---
 
 @router.post("/", response_model=ChatReadSimple, status_code=status.HTTP_201_CREATED)
-def create_new_chat(*, db: Session = Depends(get_db), user_id: uuid.UUID = Depends(get_current_user)):
+async def create_new_chat(*, db: AsyncSession = Depends(get_db), user_id: uuid.UUID = Depends(get_current_user)):
     """Creates a new, empty chat for the authenticated user."""
-    return chat_crud.create_chat(db=db, user_id=user_id)
+    return await chat_crud.create_chat(db=db, user_id=user_id)
 
 @router.get("/", response_model=List[ChatReadSimple])
-def get_user_chats(*, db: Session = Depends(get_db), user_id: uuid.UUID = Depends(get_current_user)):
+async def get_user_chats(*, db: AsyncSession = Depends(get_db), user_id: uuid.UUID = Depends(get_current_user)):
     """Retrieves all chats for the authenticated user."""
-    return chat_crud.get_chats_by_user(db=db, user_id=user_id)
+    return await chat_crud.get_chats_by_user(db=db, user_id=user_id)
 
 @router.get("/{chat_id}", response_model=ChatReadWithMessages)
-def get_single_chat_with_messages(*, chat_id: uuid.UUID, user_id: uuid.UUID = Depends(get_current_user), db: Session = Depends(get_db)):
+async def get_single_chat_with_messages(*, chat_id: uuid.UUID, user_id: uuid.UUID = Depends(get_current_user), db: AsyncSession = Depends(get_db)):
     """Retrieves a specific chat with all its messages."""
-    chat = get_chat_for_user(chat_id, user_id, db)
+    chat = await get_chat_for_user(chat_id, user_id, db)
     filtered_messages = [
         msg for msg in chat.messages
         if msg.role == 'user' or (msg.role == 'assistant' and msg.content)
@@ -83,16 +83,16 @@ def get_single_chat_with_messages(*, chat_id: uuid.UUID, user_id: uuid.UUID = De
     )
 
 @router.patch("/{chat_id}", response_model=ChatReadSimple)
-def rename_chat(*, chat_id: uuid.UUID, chat_update: ChatUpdate, user_id: uuid.UUID = Depends(get_current_user), db: Session = Depends(get_db)):
+async def rename_chat(*, chat_id: uuid.UUID, chat_update: ChatUpdate, user_id: uuid.UUID = Depends(get_current_user), db: AsyncSession = Depends(get_db)):
     """Renames a specific chat."""
-    chat = get_chat_for_user(chat_id, user_id, db)
-    return chat_crud.update_chat_title(db=db, chat=chat, chat_update=chat_update)
+    chat = await get_chat_for_user(chat_id, user_id, db)
+    return await chat_crud.update_chat_title(db=db, chat=chat, chat_update=chat_update)
 
 @router.delete("/{chat_id}", status_code=status.HTTP_204_NO_CONTENT)
-def remove_chat(*, chat_id: uuid.UUID, user_id: uuid.UUID = Depends(get_current_user), db: Session = Depends(get_db)):
+async def remove_chat(*, chat_id: uuid.UUID, user_id: uuid.UUID = Depends(get_current_user), db: AsyncSession = Depends(get_db)):
     """Deletes a specific chat and all its messages."""
-    chat = get_chat_for_user(chat_id, user_id, db)
-    chat_crud.delete_chat(db=db, chat=chat)
+    chat = await get_chat_for_user(chat_id, user_id, db)
+    await chat_crud.delete_chat(db=db, chat=chat)
     return
 
 
@@ -104,16 +104,16 @@ async def post_message_and_get_response(
     chat_id: uuid.UUID,
     message_in: MessageCreate,
     user_id: uuid.UUID = Depends(get_current_user),
-    db: Session = Depends(get_db)
+    db: AsyncSession = Depends(get_db)
 ):
     """
     Handles a user's message by invoking the agent and persisting the full turn.
     """
     # 1. Get and verify chat ownership
-    chat = get_chat_for_user(chat_id, user_id, db)
+    chat = await get_chat_for_user(chat_id, user_id, db)
 
     # 2. Load and convert history for the agent
-    db_messages = message_crud.get_messages_by_chat(db, chat_id)
+    db_messages = await message_crud.get_messages_by_chat(db, chat_id)
     is_first_user_message = not db_messages
     messages_for_agent: list[BaseMessage] = _convert_db_messages_to_langchain(db_messages)
 
@@ -132,7 +132,7 @@ async def post_message_and_get_response(
     new_lc_messages = updated_messages_from_agent[initial_message_count - 1:]
 
     # 7. Atomically persist the entire turn to the database
-    final_ai_message  = message_crud.create_messages_for_turn(
+    final_ai_message  = await message_crud.create_messages_for_turn(
         db=db,
         chat_id=chat_id,
         new_lc_messages=new_lc_messages,
@@ -143,6 +143,6 @@ async def post_message_and_get_response(
     # 8. If this was the first message, generate and set a title for the chat
     if is_first_user_message:
         new_title = await generate_chat_title(message_in.content)
-        chat_crud.update_chat_title(db=db, chat=chat, chat_update=ChatUpdate(title=new_title))
+        await chat_crud.update_chat_title(db=db, chat=chat, chat_update=ChatUpdate(title=new_title))
 
     return final_ai_message

db/crud/chat.py

@@ -1,49 +1,41 @@
 import uuid
 from datetime import datetime, timezone
 from typing import Optional
+
+from sqlalchemy.ext.asyncio import AsyncSession
 from sqlmodel import Session, select
 
 from db.models.chat import Chat
 from db.schemas.chat import ChatUpdate
 
-def create_chat(db: Session, user_id: uuid.UUID) -> Chat:
-    """
-    Creates a new, empty chat for a specific user.
-    """
+async def create_chat(db: AsyncSession, user_id: uuid.UUID) -> Chat:
+    """Creates a new, empty chat for a specific user asynchronously."""
     db_chat = Chat(user_id=user_id)
     db.add(db_chat)
-    db.commit()
-    db.refresh(db_chat)
+    await db.commit()
+    await db.refresh(db_chat)
     return db_chat
 
-def get_chats_by_user(db: Session, user_id: uuid.UUID) -> list[Chat]:
-    """
-    Retrieves all chats for a specific user, sorted by the most recently updated.
-    """
+async def get_chats_by_user(db: AsyncSession, user_id: uuid.UUID) -> list[Chat]:
+    """Retrieves all chats for a specific user, sorted by the most recently updated."""
     statement = select(Chat).where(Chat.user_id == user_id).order_by(Chat.updated_at.desc())
-    return db.exec(statement).all()
+    result = await db.exec(statement)
+    return result.all()
 
-def get_chat_by_id(db: Session, chat_id: uuid.UUID) -> Optional[Chat]:
-    """
-    Retrieves a single chat by its unique ID.
-    Returns None if the chat does not exist.
-    """
-    return db.get(Chat, chat_id)
+async def get_chat_by_id(db: AsyncSession, chat_id: uuid.UUID) -> Optional[Chat]:
+    """Retrieves a single chat by its unique ID."""
+    return await db.get(Chat, chat_id)
 
-def update_chat_title(db: Session, chat: Chat, chat_update: ChatUpdate) -> Chat:
-    """
-    Updates a chat's title and its updated_at timestamp.
-    """
+async def update_chat_title(db: AsyncSession, chat: Chat, chat_update: ChatUpdate) -> Chat:
+    """Updates a chat's title and its updated_at timestamp."""
     chat.title = chat_update.title
     chat.updated_at = datetime.now(timezone.utc)
     db.add(chat)
-    db.commit()
-    db.refresh(chat)
+    await db.commit()
+    await db.refresh(chat)
     return chat
 
-def delete_chat(db: Session, chat: Chat) -> None:
-    """
-    Deletes a chat from the database.
-    """
-    db.delete(chat)
-    db.commit()
+async def delete_chat(db: AsyncSession, chat: Chat) -> None:
+    """Deletes a chat from the database."""
+    await db.delete(chat)
+    await db.commit()

db/crud/message.py

@@ -1,5 +1,6 @@
 import uuid
-from sqlmodel import Session, select
+from sqlmodel import select
+from sqlalchemy.ext.asyncio import AsyncSession
 from datetime import datetime, timezone
 
 from db.models.chat import Chat
@@ -7,8 +8,8 @@ from db.models.message import Message
 from langchain_core.messages import BaseMessage, HumanMessage, AIMessage, ToolMessage
 
 
-def create_messages_for_turn(
-    db: Session,
+async def create_messages_for_turn(
+    db: AsyncSession,
     chat_id: uuid.UUID,
     new_lc_messages: list[BaseMessage],
     final_answer: str,
@@ -34,7 +35,7 @@ def create_messages_for_turn(
     """
     # First, get the parent chat to update its timestamp.
     # This also ensures the chat exists before we try to add messages to it.
-    chat = db.get(Chat, chat_id)
+    chat = await db.get(Chat, chat_id)
     if not chat:
         # Or raise a custom exception that can be caught by the API layer
         raise ValueError("Chat not found")
@@ -73,17 +74,17 @@ def create_messages_for_turn(
         db_messages_to_add.append(db_msg)
 
     # Use add_all for efficient bulk insertion
-    db.add_all(db_messages_to_add)
-    db.commit()
+    await db.add_all(db_messages_to_add)
+    await db.commit()
 
     # Only refresh the single message we need to return to the client.
     final_ai_message = db_messages_to_add[-1]
-    db.refresh(final_ai_message)
+    await db.refresh(final_ai_message)
 
     return final_ai_message
 
 
-def get_messages_by_chat(db: Session, chat_id: uuid.UUID) -> list[Message]:
+async def get_messages_by_chat(db: AsyncSession, chat_id: uuid.UUID) -> list[Message]:
     """
     Retrieves all messages for a specific chat, sorted by creation time
     to ensure correct conversation order.
@@ -93,4 +94,4 @@ def get_messages_by_chat(db: Session, chat_id: uuid.UUID) -> list[Message]:
         .where(Message.chat_id == chat_id)
         .order_by(Message.created_at.asc())
     )
-    return db.exec(statement).all()
+    return await db.exec(statement).all()

db/session.py

@@ -1,26 +1,34 @@
-from sqlmodel import SQLModel, create_engine, Session
+from sqlmodel import SQLModel
+from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession
+from sqlalchemy.orm import sessionmaker
 
-from db.models import Chat, Message
 from core.config import get_settings
 
 settings = get_settings()
 
-engine = create_engine(
+async_engine = create_async_engine(
     settings.DATABASE_URL,
+    echo=False,
+    future=True,
     pool_pre_ping=True,
-    connect_args=settings.DB_CONNECT_ARGS
 )
 
-def get_db():
+# Use sessionmaker for async sessions
+AsyncSessionLocal = sessionmaker(
+    autocommit=False, autoflush=False, bind=async_engine, class_=AsyncSession
+)
+
+async def get_db():
     """
-    Dependency function to get a database session.
+    Dependency function to get an async database session.
     Ensures the session is always closed after the request.
     """
-    with Session(engine) as session:
+    async with AsyncSessionLocal() as session:
         yield session
 
-def create_db_and_tables():
+async def create_db_and_tables():
     """
-    Utility function to create database tables.
+    Utility function to create database tables asynchronously.
     """
-    SQLModel.metadata.create_all(engine)
+    async with async_engine.begin() as conn:
+        await conn.run_sync(SQLModel.metadata.create_all)

main.py

@@ -12,7 +12,7 @@ settings = get_settings()
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     print(f"INFO:     Starting up {settings.APP_NAME} v{settings.APP_VERSION}...")
-    create_db_and_tables()
+    await create_db_and_tables()
     print("INFO:     Database tables checked/created.")
     yield
     print(f"INFO:     Shutting down {settings.APP_NAME}...")

pyproject.toml

@@ -5,6 +5,7 @@ description = "Add your description here"
 readme = "README.md"
 requires-python = ">=3.11"
 dependencies = [
+    "asyncpg>=0.30.0",
     "fastapi>=0.115.14",
     "ipykernel>=6.29.5",
     "langchain>=0.3.26",
@@ -21,6 +22,7 @@ dependencies = [
     "psycopg2-binary>=2.9.10",
     "psycopg[binary]>=3.2.9",
     "pydantic-settings>=2.10.1",
+    "python-dateutil>=2.9.0.post0",
     "python-dotenv>=1.1.1",
     "python-jose>=3.5.0",
     "sqlmodel>=0.0.24",

uv.lock

@@ -178,6 +178,38 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/fe/ba/e2081de779ca30d473f21f5b30e0e737c438205440784c7dfc81efc2b029/async_timeout-5.0.1-py3-none-any.whl", hash = "sha256:39e3809566ff85354557ec2398b55e096c8364bacac9405a7a1fa429e77fe76c", size = 6233 },
 ]
 
+[[package]]
+name = "asyncpg"
+version = "0.30.0"
+source = { registry = "https://pypi.org/simple" }
+sdist = { url = "https://files.pythonhosted.org/packages/2f/4c/7c991e080e106d854809030d8584e15b2e996e26f16aee6d757e387bc17d/asyncpg-0.30.0.tar.gz", hash = "sha256:c551e9928ab6707602f44811817f82ba3c446e018bfe1d3abecc8ba5f3eac851", size = 957746 }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/4c/0e/f5d708add0d0b97446c402db7e8dd4c4183c13edaabe8a8500b411e7b495/asyncpg-0.30.0-cp311-cp311-macosx_10_9_x86_64.whl", hash = "sha256:5e0511ad3dec5f6b4f7a9e063591d407eee66b88c14e2ea636f187da1dcfff6a", size = 674506 },
+    { url = "https://files.pythonhosted.org/packages/6a/a0/67ec9a75cb24a1d99f97b8437c8d56da40e6f6bd23b04e2f4ea5d5ad82ac/asyncpg-0.30.0-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:915aeb9f79316b43c3207363af12d0e6fd10776641a7de8a01212afd95bdf0ed", size = 645922 },
+    { url = "https://files.pythonhosted.org/packages/5c/d9/a7584f24174bd86ff1053b14bb841f9e714380c672f61c906eb01d8ec433/asyncpg-0.30.0-cp311-cp311-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:1c198a00cce9506fcd0bf219a799f38ac7a237745e1d27f0e1f66d3707c84a5a", size = 3079565 },
+    { url = "https://files.pythonhosted.org/packages/a0/d7/a4c0f9660e333114bdb04d1a9ac70db690dd4ae003f34f691139a5cbdae3/asyncpg-0.30.0-cp311-cp311-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:3326e6d7381799e9735ca2ec9fd7be4d5fef5dcbc3cb555d8a463d8460607956", size = 3109962 },
+    { url = "https://files.pythonhosted.org/packages/3c/21/199fd16b5a981b1575923cbb5d9cf916fdc936b377e0423099f209e7e73d/asyncpg-0.30.0-cp311-cp311-musllinux_1_2_aarch64.whl", hash = "sha256:51da377487e249e35bd0859661f6ee2b81db11ad1f4fc036194bc9cb2ead5056", size = 3064791 },
+    { url = "https://files.pythonhosted.org/packages/77/52/0004809b3427534a0c9139c08c87b515f1c77a8376a50ae29f001e53962f/asyncpg-0.30.0-cp311-cp311-musllinux_1_2_x86_64.whl", hash = "sha256:bc6d84136f9c4d24d358f3b02be4b6ba358abd09f80737d1ac7c444f36108454", size = 3188696 },
+    { url = "https://files.pythonhosted.org/packages/52/cb/fbad941cd466117be58b774a3f1cc9ecc659af625f028b163b1e646a55fe/asyncpg-0.30.0-cp311-cp311-win32.whl", hash = "sha256:574156480df14f64c2d76450a3f3aaaf26105869cad3865041156b38459e935d", size = 567358 },
+    { url = "https://files.pythonhosted.org/packages/3c/0a/0a32307cf166d50e1ad120d9b81a33a948a1a5463ebfa5a96cc5606c0863/asyncpg-0.30.0-cp311-cp311-win_amd64.whl", hash = "sha256:3356637f0bd830407b5597317b3cb3571387ae52ddc3bca6233682be88bbbc1f", size = 629375 },
+    { url = "https://files.pythonhosted.org/packages/4b/64/9d3e887bb7b01535fdbc45fbd5f0a8447539833b97ee69ecdbb7a79d0cb4/asyncpg-0.30.0-cp312-cp312-macosx_10_13_x86_64.whl", hash = "sha256:c902a60b52e506d38d7e80e0dd5399f657220f24635fee368117b8b5fce1142e", size = 673162 },
+    { url = "https://files.pythonhosted.org/packages/6e/eb/8b236663f06984f212a087b3e849731f917ab80f84450e943900e8ca4052/asyncpg-0.30.0-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:aca1548e43bbb9f0f627a04666fedaca23db0a31a84136ad1f868cb15deb6e3a", size = 637025 },
+    { url = "https://files.pythonhosted.org/packages/cc/57/2dc240bb263d58786cfaa60920779af6e8d32da63ab9ffc09f8312bd7a14/asyncpg-0.30.0-cp312-cp312-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:6c2a2ef565400234a633da0eafdce27e843836256d40705d83ab7ec42074efb3", size = 3496243 },
+    { url = "https://files.pythonhosted.org/packages/f4/40/0ae9d061d278b10713ea9021ef6b703ec44698fe32178715a501ac696c6b/asyncpg-0.30.0-cp312-cp312-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:1292b84ee06ac8a2ad8e51c7475aa309245874b61333d97411aab835c4a2f737", size = 3575059 },
+    { url = "https://files.pythonhosted.org/packages/c3/75/d6b895a35a2c6506952247640178e5f768eeb28b2e20299b6a6f1d743ba0/asyncpg-0.30.0-cp312-cp312-musllinux_1_2_aarch64.whl", hash = "sha256:0f5712350388d0cd0615caec629ad53c81e506b1abaaf8d14c93f54b35e3595a", size = 3473596 },
+    { url = "https://files.pythonhosted.org/packages/c8/e7/3693392d3e168ab0aebb2d361431375bd22ffc7b4a586a0fc060d519fae7/asyncpg-0.30.0-cp312-cp312-musllinux_1_2_x86_64.whl", hash = "sha256:db9891e2d76e6f425746c5d2da01921e9a16b5a71a1c905b13f30e12a257c4af", size = 3641632 },
+    { url = "https://files.pythonhosted.org/packages/32/ea/15670cea95745bba3f0352341db55f506a820b21c619ee66b7d12ea7867d/asyncpg-0.30.0-cp312-cp312-win32.whl", hash = "sha256:68d71a1be3d83d0570049cd1654a9bdfe506e794ecc98ad0873304a9f35e411e", size = 560186 },
+    { url = "https://files.pythonhosted.org/packages/7e/6b/fe1fad5cee79ca5f5c27aed7bd95baee529c1bf8a387435c8ba4fe53d5c1/asyncpg-0.30.0-cp312-cp312-win_amd64.whl", hash = "sha256:9a0292c6af5c500523949155ec17b7fe01a00ace33b68a476d6b5059f9630305", size = 621064 },
+    { url = "https://files.pythonhosted.org/packages/3a/22/e20602e1218dc07692acf70d5b902be820168d6282e69ef0d3cb920dc36f/asyncpg-0.30.0-cp313-cp313-macosx_10_13_x86_64.whl", hash = "sha256:05b185ebb8083c8568ea8a40e896d5f7af4b8554b64d7719c0eaa1eb5a5c3a70", size = 670373 },
+    { url = "https://files.pythonhosted.org/packages/3d/b3/0cf269a9d647852a95c06eb00b815d0b95a4eb4b55aa2d6ba680971733b9/asyncpg-0.30.0-cp313-cp313-macosx_11_0_arm64.whl", hash = "sha256:c47806b1a8cbb0a0db896f4cd34d89942effe353a5035c62734ab13b9f938da3", size = 634745 },
+    { url = "https://files.pythonhosted.org/packages/8e/6d/a4f31bf358ce8491d2a31bfe0d7bcf25269e80481e49de4d8616c4295a34/asyncpg-0.30.0-cp313-cp313-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:9b6fde867a74e8c76c71e2f64f80c64c0f3163e687f1763cfaf21633ec24ec33", size = 3512103 },
+    { url = "https://files.pythonhosted.org/packages/96/19/139227a6e67f407b9c386cb594d9628c6c78c9024f26df87c912fabd4368/asyncpg-0.30.0-cp313-cp313-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:46973045b567972128a27d40001124fbc821c87a6cade040cfcd4fa8a30bcdc4", size = 3592471 },
+    { url = "https://files.pythonhosted.org/packages/67/e4/ab3ca38f628f53f0fd28d3ff20edff1c975dd1cb22482e0061916b4b9a74/asyncpg-0.30.0-cp313-cp313-musllinux_1_2_aarch64.whl", hash = "sha256:9110df111cabc2ed81aad2f35394a00cadf4f2e0635603db6ebbd0fc896f46a4", size = 3496253 },
+    { url = "https://files.pythonhosted.org/packages/ef/5f/0bf65511d4eeac3a1f41c54034a492515a707c6edbc642174ae79034d3ba/asyncpg-0.30.0-cp313-cp313-musllinux_1_2_x86_64.whl", hash = "sha256:04ff0785ae7eed6cc138e73fc67b8e51d54ee7a3ce9b63666ce55a0bf095f7ba", size = 3662720 },
+    { url = "https://files.pythonhosted.org/packages/e7/31/1513d5a6412b98052c3ed9158d783b1e09d0910f51fbe0e05f56cc370bc4/asyncpg-0.30.0-cp313-cp313-win32.whl", hash = "sha256:ae374585f51c2b444510cdf3595b97ece4f233fde739aa14b50e0d64e8a7a590", size = 560404 },
+    { url = "https://files.pythonhosted.org/packages/c8/a4/cec76b3389c4c5ff66301cd100fe88c318563ec8a520e0b2e792b5b84972/asyncpg-0.30.0-cp313-cp313-win_amd64.whl", hash = "sha256:f59b430b8e27557c3fb9869222559f7417ced18688375825f8f12302c34e915e", size = 621623 },
+]
+
 [[package]]
 name = "attrs"
 version = "25.3.0"
@@ -1312,6 +1344,7 @@ name = "makhfi-ai"
 version = "0.1.0"
 source = { virtual = "." }
 dependencies = [
+    { name = "asyncpg" },
     { name = "fastapi" },
     { name = "ipykernel" },
     { name = "langchain" },
@@ -1328,6 +1361,7 @@ dependencies = [
     { name = "psycopg", extra = ["binary"] },
     { name = "psycopg2-binary" },
     { name = "pydantic-settings" },
+    { name = "python-dateutil" },
     { name = "python-dotenv" },
     { name = "python-jose" },
     { name = "sqlmodel" },
@@ -1337,6 +1371,7 @@ dependencies = [
 
 [package.metadata]
 requires-dist = [
+    { name = "asyncpg", specifier = ">=0.30.0" },
     { name = "fastapi", specifier = ">=0.115.14" },
     { name = "ipykernel", specifier = ">=6.29.5" },
     { name = "langchain", specifier = ">=0.3.26" },
@@ -1353,6 +1388,7 @@ requires-dist = [
     { name = "psycopg", extras = ["binary"], specifier = ">=3.2.9" },
     { name = "psycopg2-binary", specifier = ">=2.9.10" },
     { name = "pydantic-settings", specifier = ">=2.10.1" },
+    { name = "python-dateutil", specifier = ">=2.9.0.post0" },
     { name = "python-dotenv", specifier = ">=1.1.1" },
     { name = "python-jose", specifier = ">=3.5.0" },
     { name = "sqlmodel", specifier = ">=0.0.24" },