From 5287ce6dcbff8a4491465b69cb5a109089046324 Mon Sep 17 00:00:00 2001 From: henryruhs Date: Sat, 6 Jun 2026 11:45:38 +0200 Subject: [PATCH] add todos --- facefusion/apis/stream_video.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/facefusion/apis/stream_video.py b/facefusion/apis/stream_video.py index dafb72e0..4e93f3c0 100644 --- a/facefusion/apis/stream_video.py +++ b/facefusion/apis/stream_video.py @@ -25,7 +25,8 @@ def run_video_encode_loop(rtc_peer : RtcPeer, video_queue : Queue[VideoPack]) -> temp_bitrate : BitRate = 8000 video_encoder = create_video_encoder(video_codec, temp_resolution, temp_bitrate) previous_video_time = temp_video_time - temp_deque = deque() + #todo: fix typing once issue below is sorted out + temp_deque = deque() #type:ignore[var-annotated] execution_thread_count = state_manager.get_item('execution_thread_count') frame_index = 0 @@ -33,6 +34,7 @@ def run_video_encode_loop(rtc_peer : RtcPeer, video_queue : Queue[VideoPack]) -> while numpy.any(temp_vision_frame) or temp_deque: if numpy.any(temp_vision_frame) and len(temp_deque) < execution_thread_count: + #todo: why does the deque contain a future and not just the data temp_deque.append((executor.submit(process_video_frame, temp_vision_frame), temp_video_time)) temp_vision_frame, temp_video_time = video_queue.get()