concurrecny

.github/workflows/auto-format.yaml

@@ -1,5 +1,8 @@
 name: auto-format
 on: pull_request
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
 jobs:
   format:
     # Check if the PR is not from a fork

.github/workflows/publish-dockerhub.yaml

@@ -5,6 +5,10 @@ on:
   release:
     types: [published]
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 jobs:
   push_to_registry:
     name: Push Docker image to Docker Hub

.github/workflows/unit-test.yaml

@@ -5,6 +5,10 @@ on:
     branches: [ main ]
   pull_request:
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 jobs:
   test:
     runs-on: ubuntu-latest

test/test_arg_parsing.py

@@ -1,6 +1,6 @@
 import pytest
 
-from stream import parse_motion_args, parse_resize_args, parse_stream_args
+from stream.stream import parse_motion_args, parse_resize_args, parse_stream_args
 
 
 def test_parse_resize_args():

test/test_image_processing.py

@@ -1,7 +1,7 @@
 import numpy as np
 import pytest
 
-from image_processing import crop_frame, parse_crop_string, resize_if_needed
+from stream.image_processing import crop_frame, parse_crop_string, resize_if_needed
 
 
 def test_resize_if_needed():

test/test_image_submission.py

@@ -10,7 +10,7 @@
 from framegrab import MotionDetector
 from groundlight import Groundlight
 
-from stream import process_single_frame, run_capture_loop
+from stream.stream import process_single_frame, run_capture_loop
 from test.utils import thread_logging
 
 

test/test_threads.py

@@ -3,7 +3,7 @@
 import time
 from unittest.mock import Mock
 
-from threads import ThreadControl, setup_workers, worker_loop
+from stream.threads import ThreadControl, setup_workers, worker_loop
 
 
 def test_thread_control():