diff --git a/frigate/object_processing.py b/frigate/object_processing.py index e25ebc5fa..9eaf5313f 100644 --- a/frigate/object_processing.py +++ b/frigate/object_processing.py @@ -657,7 +657,9 @@ class TrackedObjectProcessor(threading.Thread): self.last_motion_detected: dict[str, float] = {} def start(camera, obj: TrackedObject, current_frame_time): - self.event_queue.put((DetectionTypeEnum.tracked_object, "start", camera, obj.to_dict())) + self.event_queue.put( + (DetectionTypeEnum.tracked_object, "start", camera, obj.to_dict()) + ) def update(camera, obj: TrackedObject, current_frame_time): obj.has_snapshot = self.should_save_snapshot(camera, obj) @@ -671,7 +673,12 @@ class TrackedObjectProcessor(threading.Thread): self.dispatcher.publish("events", json.dumps(message), retain=False) obj.previous = after self.event_queue.put( - (DetectionTypeEnum.tracked_object, "update", camera, obj.to_dict(include_thumbnail=True)) + ( + DetectionTypeEnum.tracked_object, + "update", + camera, + obj.to_dict(include_thumbnail=True), + ) ) def end(camera, obj: TrackedObject, current_frame_time): @@ -723,7 +730,14 @@ class TrackedObjectProcessor(threading.Thread): } self.dispatcher.publish("events", json.dumps(message), retain=False) - self.event_queue.put((DetectionTypeEnum.tracked_object, "end", camera, obj.to_dict(include_thumbnail=True))) + self.event_queue.put( + ( + DetectionTypeEnum.tracked_object, + "end", + camera, + obj.to_dict(include_thumbnail=True), + ) + ) def snapshot(camera, obj: TrackedObject, current_frame_time): mqtt_config: MqttConfig = self.config.cameras[camera].mqtt