diff --git a/video_render/pipeline.py b/video_render/pipeline.py
index 39557d8..29edc93 100644
--- a/video_render/pipeline.py
+++ b/video_render/pipeline.py
@@ -69,6 +69,7 @@ class VideoPipeline:
             return self._build_success_payload(context)
         except Exception as exc:
             logger.exception("Falha ao processar vídeo %s", context.job.filename)
+            return self._handle_failure(context, exc)
 
     def _parse_job(self, message: Dict[str, Any]) -> JobMessage:
         filename = message.get("filename")