selfhostyourtech/reflector
2
0
Fork 0
mirror of https://github.com/Monadical-SAS/reflector.git synced 2026-02-04 09:56:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

correct workflow name for hatchet (#815)

Browse Source 
Co-authored-by: Igor Loskutov <igor.loskutoff@gmail.com>
This commit is contained in:
Igor Monadical
2025-12-29 20:36:36 -05:00
committed by GitHub
parent 7f42ef6d17
commit e644d6497b
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -298,7 +298,7 @@ async def _process_multitrack_recording_inner(
if use_hatchet: if use_hatchet:
workflow_id = await HatchetClientManager.start_workflow( workflow_id = await HatchetClientManager.start_workflow(
workflow_name="DailyMultitrackPipeline", workflow_name="DiarizationPipeline",
input_data={ input_data={
"recording_id": recording_id, "recording_id": recording_id,
"tracks": [{"s3_key": k} for k in filter_cam_audio_tracks(track_keys)], "tracks": [{"s3_key": k} for k in filter_cam_audio_tracks(track_keys)],
@@ -846,7 +846,7 @@ async def reprocess_failed_daily_recordings():
continue continue
workflow_id = await HatchetClientManager.start_workflow( workflow_id = await HatchetClientManager.start_workflow(
workflow_name="DailyMultitrackPipeline", workflow_name="DiarizationPipeline",
input_data={ input_data={
"recording_id": recording.id, "recording_id": recording.id,
"tracks": [ "tracks": [