selfhostyourtech/reflector
2
0
Fork 0
mirror of https://github.com/Monadical-SAS/reflector.git synced 2025-12-20 20:29:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix reprocessing

Browse Source
This commit is contained in:
Sergey Mankovsky
2025-03-11 15:32:53 +01:00
parent f43045b41c
commit e6ac972d1e
1 changed files with 4 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
server/reflector/worker/process.py
View File

@@ -184,29 +184,13 @@ async def reprocess_failed_recordings():
if not (object_key.endswith(".mp4")):
continue
recorded_at = datetime.fromisoformat(object_key[37:57])
recording = await recordings_controller.get_by_object_key(
bucket_name, object_key
)
if not recording:
recording = await recordings_controller.create(
Recording(
bucket_name=bucket_name,
object_key=object_key,
recorded_at=recorded_at,
meeting_id=meeting.id,
)
)
room_name = f"/{object_key[:36]}"
meeting = await meetings_controller.get_by_room_name(room_name)
if not meeting:
logger.warning(f"No meeting found for recording: {object_key}")
continue
room = await rooms_controller.get_by_id(meeting.room_id)
if not room:
logger.warning(f"No room found for meeting: {meeting.id}")
logger.info(f"Queueing recording for processing: {object_key}")
process_recording.delay(bucket_name, object_key)
reprocessed_count += 1
continue
transcript = None
@@ -221,9 +205,7 @@ async def reprocess_failed_recordings():
)
if transcript is None or transcript.status == "error":
logger.info(
f"Queueing recording for processing: {object_key}, meeting {meeting.id}"
)
logger.info(f"Queueing recording for processing: {object_key}")
process_recording.delay(bucket_name, object_key)
reprocessed_count += 1