testing

app.py

@@ -53,7 +53,7 @@ def process_video_parallel(video, skip_frames, dest_path, num_processes, process
     cap = cv2.VideoCapture(video)
     chunks_per_process = int(cap.get(cv2.CAP_PROP_FRAME_COUNT)) // (num_processes * skip_frames)
     count =  skip_frames * chunks_per_process * process_number
-    print(f"worker: {process_number}, process frames {count} ~ {skip_frames * chunks_per_process * (process_number + 1)}")
+    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)
         ret, frame = cap.read()
@@ -91,9 +91,9 @@ def vid2frames(url, sampling_interval=1, ext='mp4'):
    # testing..
     cap = cv2.VideoCapture(video)
     print(f'video: {video}; isOpen? : {cap.isOpened()}')
-
-    #with Pool(n_workers) as pool:
-    #    pool.map(partial(process_video_parallel, video, skip_frames, dest_path, n_workers), range(n_workers))
+    print(f'n_workers: {n_workers}')
+    with Pool(n_workers) as pool:
+        pool.map(partial(process_video_parallel, video, skip_frames, dest_path, n_workers), range(n_workers))
     return dest_path