From 32d49a59ff6b044273e258327bc9f0198826aa07 Mon Sep 17 00:00:00 2001 From: Ivan Dudnyk Date: Wed, 14 Jan 2026 16:05:42 +0100 Subject: [PATCH 1/2] Changed the existing examples who use SnapsUploder/SnapsData to use new version --- .../backend/src/core/snapping/snaps_producer.py | 9 +++++---- apps/data-collection/backend/src/requirements.txt | 2 +- integrations/hub-snaps-events/requirements.txt | 3 ++- integrations/hub-snaps-events/utils/snaps_producer.py | 7 ++++--- 4 files changed, 12 insertions(+), 9 deletions(-) diff --git a/apps/data-collection/backend/src/core/snapping/snaps_producer.py b/apps/data-collection/backend/src/core/snapping/snaps_producer.py index 70e5be3f3..848607df7 100644 --- a/apps/data-collection/backend/src/core/snapping/snaps_producer.py +++ b/apps/data-collection/backend/src/core/snapping/snaps_producer.py @@ -45,12 +45,13 @@ def process( detections=detections.detections, tracklets=tracklets ): continue - + file_name = f"{cond.name}_{int(time.time())}" + file_group = dai.FileGroup() + file_group.addImageDetectionsPair( + file_name, frame, detections) snap = SnapData( snap_name=cond.name, - file_name=f"{cond.name}_{int(time.time())}", - frame=frame, - detections=detections, + file_group=file_group, tags=cond.tags, extras=cond.make_extras(), ) diff --git a/apps/data-collection/backend/src/requirements.txt b/apps/data-collection/backend/src/requirements.txt index ac38434af..ad50c7cf2 100644 --- a/apps/data-collection/backend/src/requirements.txt +++ b/apps/data-collection/backend/src/requirements.txt @@ -1,5 +1,5 @@ depthai==3.2.1 -depthai-nodes==0.3.7 +depthai-nodes @ git+https://github.com/luxonis/depthai-nodes.git@feat/dai_dev_req opencv-python-headless~=4.10.0 numpy>=1.22 tokenizers~=0.21.0 diff --git a/integrations/hub-snaps-events/requirements.txt b/integrations/hub-snaps-events/requirements.txt index bd5223a56..0a1a51659 100644 --- a/integrations/hub-snaps-events/requirements.txt +++ b/integrations/hub-snaps-events/requirements.txt @@ -1,4 +1,5 @@ depthai==3.2.1 -depthai-nodes==0.3.7 +#depthai-nodes==0.3.7 +depthai-nodes @ git+https://github.com/luxonis/depthai-nodes.git@feat/dai_dev_req python-dotenv diff --git a/integrations/hub-snaps-events/utils/snaps_producer.py b/integrations/hub-snaps-events/utils/snaps_producer.py index 00329d444..5f0a65013 100644 --- a/integrations/hub-snaps-events/utils/snaps_producer.py +++ b/integrations/hub-snaps-events/utils/snaps_producer.py @@ -42,11 +42,12 @@ def process( return if time.time() - self._last_sent >= self._time_interval: + file_group = dai.FileGroup() + file_group.addImageDetectionsPair( + None, frame, detections) snap = SnapData( snap_name="test_snap", - file_name=None, - frame=frame, - detections=detections, + file_group=file_group, tags=["test_tag"], extras={"extra_key": "extra_value"}, ) From 2111128020070555d46a5ac72f480759ff127d79 Mon Sep 17 00:00:00 2001 From: Ivan Dudnyk Date: Wed, 14 Jan 2026 16:12:45 +0100 Subject: [PATCH 2/2] Fixed pre-commit --- .../backend/src/core/snapping/snaps_producer.py | 3 +-- integrations/hub-snaps-events/utils/snaps_producer.py | 3 +-- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/apps/data-collection/backend/src/core/snapping/snaps_producer.py b/apps/data-collection/backend/src/core/snapping/snaps_producer.py index 848607df7..c44ca4dbe 100644 --- a/apps/data-collection/backend/src/core/snapping/snaps_producer.py +++ b/apps/data-collection/backend/src/core/snapping/snaps_producer.py @@ -47,8 +47,7 @@ def process( continue file_name = f"{cond.name}_{int(time.time())}" file_group = dai.FileGroup() - file_group.addImageDetectionsPair( - file_name, frame, detections) + file_group.addImageDetectionsPair(file_name, frame, detections) snap = SnapData( snap_name=cond.name, file_group=file_group, diff --git a/integrations/hub-snaps-events/utils/snaps_producer.py b/integrations/hub-snaps-events/utils/snaps_producer.py index 5f0a65013..36e17f296 100644 --- a/integrations/hub-snaps-events/utils/snaps_producer.py +++ b/integrations/hub-snaps-events/utils/snaps_producer.py @@ -43,8 +43,7 @@ def process( if time.time() - self._last_sent >= self._time_interval: file_group = dai.FileGroup() - file_group.addImageDetectionsPair( - None, frame, detections) + file_group.addImageDetectionsPair(None, frame, detections) snap = SnapData( snap_name="test_snap", file_group=file_group,