CalvinBackup/facefusion
1
0
Fork 0
mirror of https://github.com/facefusion/facefusion.git synced 2026-06-07 13:13:53 +02:00
Code Issues Packages Projects Releases Wiki Activity

add todos

Browse Source
This commit is contained in:
henryruhs
2026-06-06 11:45:38 +02:00
parent 5d6258e17e
commit 5287ce6dcb
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
facefusion/apis/stream_video.py
+3 -1
View File
@@ -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()