From 65916c273faccf2a693f71b8950a6ae14d38a6b6 Mon Sep 17 00:00:00 2001 From: Igor Loskutov Date: Fri, 19 Dec 2025 16:59:40 -0500 Subject: [PATCH] no forced whereby recording indicator --- server/reflector/pipelines/main_live_pipeline.py | 2 +- server/reflector/worker/healthcheck.py | 6 ++++++ www/app/[roomName]/components/WherebyRoom.tsx | 4 +--- 3 files changed, 8 insertions(+), 4 deletions(-) diff --git a/server/reflector/pipelines/main_live_pipeline.py b/server/reflector/pipelines/main_live_pipeline.py index 2b6c6d07..fbe83737 100644 --- a/server/reflector/pipelines/main_live_pipeline.py +++ b/server/reflector/pipelines/main_live_pipeline.py @@ -112,7 +112,7 @@ def get_transcript(func): transcript_id = kwargs.pop("transcript_id") transcript = await transcripts_controller.get_by_id(transcript_id=transcript_id) if not transcript: - raise Exception("Transcript {transcript_id} not found") + raise Exception(f"Transcript {transcript_id} not found") # Enhanced logger with Celery task context tlogger = logger.bind(transcript_id=transcript.id) diff --git a/server/reflector/worker/healthcheck.py b/server/reflector/worker/healthcheck.py index 6cb16f38..cab6ab5b 100644 --- a/server/reflector/worker/healthcheck.py +++ b/server/reflector/worker/healthcheck.py @@ -7,6 +7,12 @@ from reflector.settings import settings logger = structlog.get_logger(__name__) +@shared_task(name="celery.ping") +def celery_ping(): + """Compatibility task for Celery 5.x - celery.ping was removed but monitoring tools still call it.""" + return "pong" + + @shared_task def healthcheck_ping(): url = settings.HEALTHCHECK_URL diff --git a/www/app/[roomName]/components/WherebyRoom.tsx b/www/app/[roomName]/components/WherebyRoom.tsx index 6fbc9eda..971788b6 100644 --- a/www/app/[roomName]/components/WherebyRoom.tsx +++ b/www/app/[roomName]/components/WherebyRoom.tsx @@ -7,7 +7,6 @@ import { useAuth } from "../../lib/AuthProvider"; import { getWherebyUrl, useWhereby } from "../../lib/wherebyClient"; import { ConsentDialogButton as BaseConsentDialogButton, - RecordingIndicator, useConsentDialog, } from "../../lib/consent"; import { assertMeetingId, MeetingId } from "../../lib/types"; @@ -71,7 +70,7 @@ export default function WherebyRoom({ meeting, room }: WherebyRoomProps) { const wherebyRoomUrl = getWherebyUrl(meeting); const meetingId = meeting.id; - const { showRecordingIndicator, showConsentButton } = useConsentDialog({ + const { showConsentButton } = useConsentDialog({ meetingId: assertMeetingId(meetingId), recordingType: meeting.recording_type, skipConsent: room.skip_consent, @@ -105,7 +104,6 @@ export default function WherebyRoom({ meeting, room }: WherebyRoomProps) { room={wherebyRoomUrl} style={{ width: "100vw", height: "100vh" }} /> - {showRecordingIndicator && } {showConsentButton && (