From d2ec7a0b24f34dc114183de335f02ddbd48386a7 Mon Sep 17 00:00:00 2001
From: Juan <juandgoc@gmail.com>
Date: Wed, 1 Apr 2026 20:28:31 -0500
Subject: [PATCH] fix: agg to webm for no padding

---
 .../reflector/hatchet/workflows/daily_multitrack_pipeline.py | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/server/reflector/hatchet/workflows/daily_multitrack_pipeline.py b/server/reflector/hatchet/workflows/daily_multitrack_pipeline.py
index ec99f47b..b92ab49b 100644
--- a/server/reflector/hatchet/workflows/daily_multitrack_pipeline.py
+++ b/server/reflector/hatchet/workflows/daily_multitrack_pipeline.py
@@ -534,6 +534,11 @@ async def process_tracks(input: PipelineInput, ctx: Context) -> ProcessTracksRes
             earliest = min(ts for _, ts in valid_timestamps)
             for i, ts in valid_timestamps:
                 offset = (ts - earliest).total_seconds()
+                # LiveKit tracks are OGG format; even the earliest track (offset=0)
+                # must go through padding step to convert OGG→WebM for the
+                # transcription service. Use a tiny padding to force conversion.
+                if offset == 0.0:
+                    offset = 0.001
                 track_padding[i] = offset
                 ctx.log(
                     f"process_tracks: track {i} padding={offset}s (from filename timestamp)"