diff --git a/frigate/object_detection.py b/frigate/object_detection.py index a0c31b755..790b975d1 100644 --- a/frigate/object_detection.py +++ b/frigate/object_detection.py @@ -209,7 +209,7 @@ class RemoteObjectDetector: # copy input to shared memory self.np_shm[:] = tensor_input[:] self.event.clear() - self.detection_queue.put(self.name) + self.detection_queue.put_nowait(self.name) result = self.event.wait(timeout=5.0) # if it timed out diff --git a/frigate/object_processing.py b/frigate/object_processing.py index a818637f1..b1a0e64b0 100644 --- a/frigate/object_processing.py +++ b/frigate/object_processing.py @@ -1070,7 +1070,7 @@ class TrackedObjectProcessor(threading.Thread): o.to_dict() for o in camera_state.tracked_objects.values() ] - self.video_output_queue.put( + self.video_output_queue.put_nowait( ( camera, frame_time, diff --git a/frigate/video.py b/frigate/video.py index bf2191a3a..503114fca 100755 --- a/frigate/video.py +++ b/frigate/video.py @@ -1040,7 +1040,7 @@ def process_frames( else: fps_tracker.update() fps.value = fps_tracker.eps() - detected_objects_queue.put( + detected_objects_queue.put_nowait( ( camera_name, frame_time, diff --git a/process_clip.py b/process_clip.py index 16bf7afa4..4226ab619 100644 --- a/process_clip.py +++ b/process_clip.py @@ -152,7 +152,7 @@ class ProcessClip: current_tracked_objects, motion_boxes, regions, - ) = self.detected_objects_queue.get() + ) = self.detected_objects_queue.get_nowait() if debug_path: self.save_debug_frame(