1) Marks existing file as "removed" 2) Sets processing deferred on input to True 3) Resets status TODO limits, * ie do we allow retry of "split" videos, and if so does that need to follow different process * .
(self)
| 153 | self.retry_file() |
| 154 | |
| 155 | def retry_file(self): |
| 156 | """ |
| 157 | |
| 158 | 1) Marks existing file as "removed" |
| 159 | 2) Sets processing deferred on input to True |
| 160 | 3) Resets status |
| 161 | |
| 162 | TODO limits, |
| 163 | * ie do we allow retry of "split" videos, |
| 164 | and if so does that need to follow different |
| 165 | process |
| 166 | * ... |
| 167 | |
| 168 | """ |
| 169 | |
| 170 | if self.input.mode != "update": |
| 171 | # Important. Context of updates not creating a new file, so not wanting to |
| 172 | # remove original file. |
| 173 | self.remove_associated_file(self.input) |
| 174 | |
| 175 | self.input.processing_deferred = True |
| 176 | |
| 177 | self.input.status = "retrying" |
| 178 | self.input.status_text = "" |
| 179 | self.input.update_log = {} |
| 180 | |
| 181 | if not self.input.retry_count: |
| 182 | self.input.retry_count = 0 |
| 183 | self.input.retry_count += 1 |
| 184 | |
| 185 | if not self.input.retry_log: |
| 186 | self.input.retry_log = {} |
| 187 | |
| 188 | self.input.retry_log[datetime.datetime.utcnow().isoformat()] = self.log |
| 189 | |
| 190 | self.session.add(self.input) |
| 191 | if settings.PROCESS_MEDIA_ENQUEUE_LOCALLY_IMMEDIATELY: |
| 192 | from shared.ingest.prioritized_item import PrioritizedItem |
| 193 | from shared.system_startup.start_media_queue import process_media_queue_manager |
| 194 | item = PrioritizedItem( |
| 195 | priority = 10000, # individual frames have a priority here. |
| 196 | input_id = self.input.id, |
| 197 | media_type = self.input.media_type) |
| 198 | process_media_queue_manager.router(item) |
| 199 | |
| 200 | def archive_input(self): |
| 201 | """ |
no test coverage detected