(args)
| 68 | |
| 69 | |
| 70 | def main(args): |
| 71 | logger.info(args) |
| 72 | filepaths = read_filepaths(args) |
| 73 | |
| 74 | manager = Manager(filepaths) |
| 75 | |
| 76 | def signal_handler(signum, frame): |
| 77 | manager.filepaths = [] |
| 78 | logger.error( |
| 79 | "Got ctrl+c, set manager filepaths = [], please wait until all workers are done" |
| 80 | ) |
| 81 | |
| 82 | signal.signal(signal.SIGINT, signal_handler) |
| 83 | |
| 84 | for i in range(args.thread_number): |
| 85 | worker = Worker(i, manager) |
| 86 | worker.start() |
| 87 | |
| 88 | main_thread = threading.currentThread() |
| 89 | for t in threading.enumerate(): |
| 90 | if t is not main_thread: |
| 91 | t.join() |
| 92 | |
| 93 | |
| 94 | def save_video_to_frames(video_filename, output_dir, max_len, min_h, min_w, prefix=''): |
no test coverage detected