(
self,
input: Input)
| 467 | return input |
| 468 | |
| 469 | def __push_formatted_frame_to_queue( |
| 470 | self, |
| 471 | input: Input): |
| 472 | |
| 473 | item = PrioritizedItem( |
| 474 | input = input, |
| 475 | media_type = input.media_type, # declaring here helps with routing |
| 476 | priority = 100 + input.frame_number, # Process in frame priority |
| 477 | frame_number = input.frame_number # Careful, downstream process currently expects it |
| 478 | ) |
| 479 | |
| 480 | process_media_queue_manager.router(item) |
| 481 | |
| 482 | def add_frame_to_queue( |
| 483 | self, |
no test coverage detected