lint

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

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

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_
 

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

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