agent 2.2

models/matanyone_loader.py

@@ -989,6 +989,15 @@ def process_stream(
                         log.error(error_msg, exc_info=True)
                         _emit_progress(progress_cb, -1, f"CLEANUP ERROR: {error_msg}")
                         raise MatAnyError(error_msg) from e
+                    finally:
+                        # Ensure all resources are cleaned up
+                        if 'cap' in locals() and cap is not None:
+                            cap.release()
+                        if 'alpha_writer' in locals() and alpha_writer is not None:
+                            alpha_writer.release()
+                        if 'fg_writer' in locals() and fg_writer is not None:
+                            fg_writer.release()
+                        _safe_empty_cache()
 
     def _flush_chunk(self, frames_bgr, seed_1hw, alpha_writer, fg_writer):
         """