From d4c70be766e240847c8b7a4e6f14469ff3727d54 Mon Sep 17 00:00:00 2001
From: henryruhs <info@henryruhs.com>
Date: Tue, 3 Nov 2026 21:34:48 +0100
Subject: [PATCH] rename things in stream manager

---
 facefusion/apis/endpoints/stream.py | 3 +--
 facefusion/apis/stream_manager.py   | 3 ++-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/facefusion/apis/endpoints/stream.py b/facefusion/apis/endpoints/stream.py
index dbe64401..b777d64c 100644
--- a/facefusion/apis/endpoints/stream.py
+++ b/facefusion/apis/endpoints/stream.py
@@ -3,7 +3,7 @@ from starlette.responses import Response
 from starlette.status import HTTP_200_OK, HTTP_201_CREATED, HTTP_404_NOT_FOUND, HTTP_409_CONFLICT
 from starlette.websockets import WebSocket, WebSocketState
 
-from facefusion import process_manager, rtc_manager
+from facefusion import rtc_manager
 from facefusion.apis import websocket_manager
 from facefusion.apis.stream_manager import destroy_stream, negotiate_video, process_image
 from facefusion.apis.websocket_helper import get_sec_websocket_protocol
@@ -32,7 +32,6 @@ async def post_stream(request : Request) -> Response:
 	}
 	if not rtc_manager.has_peer():
 		sdp_offer = await request.body()
-		process_manager.start()
 		sdp_answer = negotiate_video(sdp_offer.decode())
 
 		if sdp_answer:
diff --git a/facefusion/apis/stream_manager.py b/facefusion/apis/stream_manager.py
index 4ce14bfa..9369a856 100644
--- a/facefusion/apis/stream_manager.py
+++ b/facefusion/apis/stream_manager.py
@@ -123,6 +123,7 @@ def process_video(rtc_peer : RtcPeer) -> None:
 	audio_queue : Queue[Tuple[Time, AudioFrame]] = Queue(maxsize = execution_thread_count * 10)
 	video_executor = thread_helper.create_executor(execution_thread_count)
 
+	process_manager.start()
 	video_receiver_thread = threading.Thread(
 		target = copy_context().run,
 		args = (receive_video_frames, rtc_peer.get('video'), video_queue, video_executor),
@@ -156,8 +157,8 @@ def process_video(rtc_peer : RtcPeer) -> None:
 	video_encoder_thread.join()
 	video_executor.shutdown(wait = True)
 
-	process_manager.end()
 	rtc_manager.delete_peer()
+	process_manager.end()
 
 
 def destroy_stream() -> bool: