diff --git a/server/reflector/db/meetings.py b/server/reflector/db/meetings.py index 40845f02..9e2f89bd 100644 --- a/server/reflector/db/meetings.py +++ b/server/reflector/db/meetings.py @@ -144,7 +144,7 @@ class MeetingController: sa.and_( meetings.c.room_id == room.id, meetings.c.end_date > current_time, - meetings.c.is_active == True, + meetings.c.is_active, ) ) .order_by(end_date.desc()) @@ -229,7 +229,7 @@ class MeetingConsentController: """Check if any participant denied consent for this meeting""" query = meeting_consent.select().where( meeting_consent.c.meeting_id == meeting_id, - meeting_consent.c.consent_given == False + meeting_consent.c.consent_given.is_(False) ) result = await database.fetch_one(query) return result is not None diff --git a/server/reflector/db/recordings.py b/server/reflector/db/recordings.py index 5d485e02..4b517754 100644 --- a/server/reflector/db/recordings.py +++ b/server/reflector/db/recordings.py @@ -1,6 +1,5 @@ from datetime import datetime from typing import Literal -from uuid import uuid4 import sqlalchemy as sa from pydantic import BaseModel, Field diff --git a/server/reflector/db/transcripts.py b/server/reflector/db/transcripts.py index c865a409..524de3ed 100644 --- a/server/reflector/db/transcripts.py +++ b/server/reflector/db/transcripts.py @@ -14,7 +14,7 @@ from pydantic import BaseModel, ConfigDict, Field from reflector.db import database, metadata from reflector.processors.types import Word as ProcessorWord from reflector.settings import settings -from reflector.storage import Storage, get_transcripts_storage +from reflector.storage import get_transcripts_storage from sqlalchemy import Enum from sqlalchemy.sql import false, or_ diff --git a/server/reflector/pipelines/main_live_pipeline.py b/server/reflector/pipelines/main_live_pipeline.py index 62ea7a33..8b00b9eb 100644 --- a/server/reflector/pipelines/main_live_pipeline.py +++ b/server/reflector/pipelines/main_live_pipeline.py @@ -60,8 +60,7 @@ from reflector.zulip import ( update_zulip_message, ) -from reflector.db.meetings import meetings_controller, meeting_consent_controller -from reflector.db.recordings import recordings_controller +from reflector.db.meetings import meeting_consent_controller from reflector.storage import get_transcripts_storage import boto3 diff --git a/server/reflector/worker/process.py b/server/reflector/worker/process.py index 5697f075..706396bb 100644 --- a/server/reflector/worker/process.py +++ b/server/reflector/worker/process.py @@ -13,7 +13,6 @@ from reflector.db.meetings import meetings_controller from reflector.db.recordings import Recording, recordings_controller from reflector.db.rooms import rooms_controller from reflector.db.transcripts import SourceKind, transcripts_controller -from reflector.storage import get_transcripts_storage from reflector.pipelines.main_live_pipeline import asynctask, task_pipeline_process from reflector.settings import settings from reflector.whereby import get_room_sessions