skip_frames=1

app.py

@@ -55,7 +55,8 @@ def process_video_parallel(video, skip_frames, dest_path, num_processes, process
     count =  skip_frames * chunks_per_process * process_number
     print(f"worker: {process_number}, process frames {count} ~ {skip_frames * chunks_per_process * (process_number + 1)} \n total number of frames: {cap.get(cv2.CAP_PROP_FRAME_COUNT)} \n video: {video}; isOpen? : {cap.isOpened()}")
     while count < skip_frames * chunks_per_process * (process_number + 1) :
-        cap.set(cv2.CAP_PROP_POS_FRAMES, count)
+        if skip_frames > 1: 
+            cap.set(cv2.CAP_PROP_POS_FRAMES, count)
         ret, frame = cap.read()
         if not ret:
             break
@@ -85,6 +86,9 @@ def vid2frames(url, sampling_interval=1, ext='mp4'):
         skip_frames = int(fps * sampling_interval)
     except:
         skip_frames = int(30 * sampling_interval)
+
+    # testing
+    skip_frames = 1
     print(f'video saved at: {video}, fps:{fps}, skip_frames: {skip_frames}')
     # extract video frames at given sampling interval with multiprocessing - 
     print('extracting frames...')