(self)
| 2269 | self.try_to_commit() |
| 2270 | |
| 2271 | def process_video(self): |
| 2272 | |
| 2273 | global New_video # important |
| 2274 | |
| 2275 | try: |
| 2276 | print(New_video) |
| 2277 | except: |
| 2278 | from methods.video.video import New_video |
| 2279 | |
| 2280 | new_video = New_video( |
| 2281 | session = self.session, |
| 2282 | project = self.project, |
| 2283 | input = self.input |
| 2284 | ) |
| 2285 | |
| 2286 | # TODO Would prefer to just pass input here |
| 2287 | # Not redeclaring |
| 2288 | |
| 2289 | try: |
| 2290 | self.populate_new_models_and_runs() |
| 2291 | file = new_video.load( |
| 2292 | video_file_name = self.input.temp_dir_path_and_filename, |
| 2293 | original_filename = self.input.original_filename, |
| 2294 | extension = self.input.extension, |
| 2295 | input = self.input, |
| 2296 | directory_id = self.input.directory_id) |
| 2297 | |
| 2298 | |
| 2299 | except Exception as e: |
| 2300 | self.input.status = 'failed' |
| 2301 | self.log['error']['process_video'] = f"Failed To process video: {traceback.format_exc()}" |
| 2302 | self.input.update_log = self.log |
| 2303 | logger.error(f"Failed To process video: {traceback.format_exc()}") |
| 2304 | |
| 2305 | self.clean_up_temp_dir_on_thread() |
| 2306 | |
| 2307 | def clean_up_temp_dir_on_thread(self, wait_time = 0): |
| 2308 |
nothing calls this directly
no test coverage detected