From 88e0d11ccdca78f3379041361133b1c912439cd8 Mon Sep 17 00:00:00 2001 From: Igor Monadical Date: Fri, 23 Jan 2026 19:59:32 -0500 Subject: [PATCH] Update server/reflector/hatchet/workflows/padding_workflow.py Co-authored-by: pr-agent-monadical[bot] <198624643+pr-agent-monadical[bot]@users.noreply.github.com> --- .../hatchet/workflows/padding_workflow.py | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/server/reflector/hatchet/workflows/padding_workflow.py b/server/reflector/hatchet/workflows/padding_workflow.py index fa8225d4..4aa63030 100644 --- a/server/reflector/hatchet/workflows/padding_workflow.py +++ b/server/reflector/hatchet/workflows/padding_workflow.py @@ -69,14 +69,15 @@ async def pad_track(input: PaddingInput, ctx: Context) -> PadTrackResult: ) with av.open(source_url) as in_container: - if in_container.duration: - try: - duration = timedelta(seconds=in_container.duration // 1_000_000) - ctx.log( - f"pad_track: track {input.track_index}, duration={duration}" - ) - except Exception: - ctx.log(f"pad_track: track {input.track_index}, duration=ERROR") + with av.open(source_url) as in_container: + if in_container.duration: + try: + duration = timedelta(seconds=in_container.duration // 1_000_000) + ctx.log( + f"pad_track: track {input.track_index}, duration={duration}" + ) + except (ValueError, TypeError, OverflowError) as e: + ctx.log(f"pad_track: track {input.track_index}, duration error: {str(e)}") start_time_seconds = extract_stream_start_time_from_container( in_container, input.track_index, logger=logger