(self, input)
| 210 | self.session.add(input) |
| 211 | |
| 212 | def remove_copied_file(self, input): |
| 213 | if input.mode == 'copy_file' and input.newly_copied_file: |
| 214 | input.newly_copied_file.state = "removed" |
| 215 | self.log['info']['removed_copied_file_id'] = input.newly_copied_file.id |
| 216 | |
| 217 | def remove_associated_tasks(self, file): |
| 218 | tasks = self.session.query(Task).filter( |