Spaces:
Build error
Build error
Sarp Bilgiç commited on
Commit ·
ae7bbe9
1
Parent(s): 5fc3272
timezone fix migration
Browse files
alembic/versions/34aaf324bd00_time_fix.py
ADDED
|
@@ -0,0 +1,33 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1 |
+
"""time fix
|
| 2 |
+
|
| 3 |
+
Revision ID: 34aaf324bd00
|
| 4 |
+
Revises: 56affd716c7c
|
| 5 |
+
Create Date: 2026-01-05 18:38:17.290937
|
| 6 |
+
|
| 7 |
+
"""
|
| 8 |
+
from typing import Sequence, Union
|
| 9 |
+
|
| 10 |
+
from alembic import op
|
| 11 |
+
import sqlalchemy as sa
|
| 12 |
+
import sqlmodel
|
| 13 |
+
|
| 14 |
+
|
| 15 |
+
# revision identifiers, used by Alembic.
|
| 16 |
+
revision: str = '34aaf324bd00'
|
| 17 |
+
down_revision: Union[str, Sequence[str], None] = '56affd716c7c'
|
| 18 |
+
branch_labels: Union[str, Sequence[str], None] = None
|
| 19 |
+
depends_on: Union[str, Sequence[str], None] = None
|
| 20 |
+
|
| 21 |
+
|
| 22 |
+
def upgrade() -> None:
|
| 23 |
+
"""Upgrade schema."""
|
| 24 |
+
# ### commands auto generated by Alembic - please adjust! ###
|
| 25 |
+
pass
|
| 26 |
+
# ### end Alembic commands ###
|
| 27 |
+
|
| 28 |
+
|
| 29 |
+
def downgrade() -> None:
|
| 30 |
+
"""Downgrade schema."""
|
| 31 |
+
# ### commands auto generated by Alembic - please adjust! ###
|
| 32 |
+
pass
|
| 33 |
+
# ### end Alembic commands ###
|
src/api/models/chat.py
CHANGED
|
@@ -33,6 +33,6 @@ class ChatMessage(SQLModel, table=True):
|
|
| 33 |
id: Optional[int] = Field(default=None, primary_key=True)
|
| 34 |
content: str = Field(sa_type=Text)
|
| 35 |
role: ChatMessageRole = Field(index=True)
|
| 36 |
-
timestamp: datetime = Field(default_factory=
|
| 37 |
session_id: uuid.UUID = Field(foreign_key="chat_sessions.id")
|
| 38 |
session: ChatSession = Relationship(back_populates="messages")
|
|
|
|
| 33 |
id: Optional[int] = Field(default=None, primary_key=True)
|
| 34 |
content: str = Field(sa_type=Text)
|
| 35 |
role: ChatMessageRole = Field(index=True)
|
| 36 |
+
timestamp: datetime = Field(default_factory=utc_now)
|
| 37 |
session_id: uuid.UUID = Field(foreign_key="chat_sessions.id")
|
| 38 |
session: ChatSession = Relationship(back_populates="messages")
|
src/api/selectors/chat/save_messages.py
CHANGED
|
@@ -3,7 +3,6 @@ from sqlmodel import select, delete
|
|
| 3 |
from src.api.models.chat import ChatSession, ChatMessage, ChatMessageRole
|
| 4 |
from llama_index.core.llms import ChatMessage as LlamaChatMessage, MessageRole
|
| 5 |
from typing import List
|
| 6 |
-
from datetime import datetime, timezone
|
| 7 |
|
| 8 |
def llama_to_db_role(llama_role: MessageRole) -> ChatMessageRole:
|
| 9 |
mapping = {
|
|
@@ -26,7 +25,6 @@ async def save_messages_to_db(
|
|
| 26 |
await db.commit()
|
| 27 |
|
| 28 |
db_messages = []
|
| 29 |
-
now = datetime.now(timezone.utc)
|
| 30 |
for i, msg in enumerate(messages):
|
| 31 |
db_message = ChatMessage(
|
| 32 |
content=str(msg.content),
|
|
|
|
| 3 |
from src.api.models.chat import ChatSession, ChatMessage, ChatMessageRole
|
| 4 |
from llama_index.core.llms import ChatMessage as LlamaChatMessage, MessageRole
|
| 5 |
from typing import List
|
|
|
|
| 6 |
|
| 7 |
def llama_to_db_role(llama_role: MessageRole) -> ChatMessageRole:
|
| 8 |
mapping = {
|
|
|
|
| 25 |
await db.commit()
|
| 26 |
|
| 27 |
db_messages = []
|
|
|
|
| 28 |
for i, msg in enumerate(messages):
|
| 29 |
db_message = ChatMessage(
|
| 30 |
content=str(msg.content),
|