From ae697df4c9ece17815f5cb0cc0069dc29ddfec66 Mon Sep 17 00:00:00 2001 From: Josako Date: Fri, 27 Sep 2024 11:24:43 +0200 Subject: [PATCH] Session_id was not correctly stored for chat sessions, and it was defined as an integer iso a UUID in the database --- common/models/monitoring.py | 4 +- eveai_chat_workers/tasks.py | 2 +- ...f07d44_session_id_is_uuid_iso_integeger.py | 38 +++++++++++++++++++ 3 files changed, 41 insertions(+), 3 deletions(-) create mode 100644 migrations/public/versions/829094f07d44_session_id_is_uuid_iso_integeger.py diff --git a/common/models/monitoring.py b/common/models/monitoring.py index 2655e72..283a6f6 100644 --- a/common/models/monitoring.py +++ b/common/models/monitoring.py @@ -14,8 +14,8 @@ class BusinessEventLog(db.Model): span_name = db.Column(db.String(50)) parent_span_id = db.Column(db.String(50)) document_version_id = db.Column(db.Integer) - chat_session_id = db.Column(db.Integer) + chat_session_id = db.Column(db.String(50)) interaction_id = db.Column(db.Integer) environment = db.Column(db.String(20)) message = db.Column(db.Text) - # Add any other fields relevant for invoicing or warnings \ No newline at end of file + # Add any other fields relevant for invoicing or warnings diff --git a/eveai_chat_workers/tasks.py b/eveai_chat_workers/tasks.py index ae8eb64..89135f7 100644 --- a/eveai_chat_workers/tasks.py +++ b/eveai_chat_workers/tasks.py @@ -67,7 +67,7 @@ def ask_question(tenant_id, question, language, session_id, user_timezone, room) 'interaction_id': 'interaction_id_value' } """ - with BusinessEvent("Ask Question", tenant_id=tenant_id, session_id=session_id): + with BusinessEvent("Ask Question", tenant_id=tenant_id, chat_session_id=session_id): current_app.logger.info(f'ask_question: Received question for tenant {tenant_id}: {question}. Processing...') try: diff --git a/migrations/public/versions/829094f07d44_session_id_is_uuid_iso_integeger.py b/migrations/public/versions/829094f07d44_session_id_is_uuid_iso_integeger.py new file mode 100644 index 0000000..6cc3abf --- /dev/null +++ b/migrations/public/versions/829094f07d44_session_id_is_uuid_iso_integeger.py @@ -0,0 +1,38 @@ +"""session_id is uuid iso integeger + +Revision ID: 829094f07d44 +Revises: 2cbdb23ae02e +Create Date: 2024-09-27 09:19:13.201988 + +""" +from alembic import op +import sqlalchemy as sa + + +# revision identifiers, used by Alembic. +revision = '829094f07d44' +down_revision = '2cbdb23ae02e' +branch_labels = None +depends_on = None + + +def upgrade(): + # ### commands auto generated by Alembic - please adjust! ### + with op.batch_alter_table('business_event_log', schema=None) as batch_op: + batch_op.alter_column('chat_session_id', + existing_type=sa.INTEGER(), + type_=sa.String(length=50), + existing_nullable=True) + + # ### end Alembic commands ### + + +def downgrade(): + # ### commands auto generated by Alembic - please adjust! ### + with op.batch_alter_table('business_event_log', schema=None) as batch_op: + batch_op.alter_column('chat_session_id', + existing_type=sa.String(length=50), + type_=sa.INTEGER(), + existing_nullable=True) + + # ### end Alembic commands ###