Merge completed task work back in to original directory
(session,
job,
task)
| 187 | |
| 188 | |
| 189 | def merge_task(session, |
| 190 | job, |
| 191 | task): |
| 192 | """ |
| 193 | |
| 194 | Merge completed task work back in to original directory |
| 195 | |
| 196 | """ |
| 197 | # Merge back to PROJECT directory |
| 198 | |
| 199 | directory_id = job.completion_directory_id |
| 200 | if directory_id is None: |
| 201 | directory_id = job.project.directory_default_id |
| 202 | |
| 203 | file_id = task.file_original_id |
| 204 | |
| 205 | link = WorkingDirFileLink.file_link(session = session, |
| 206 | working_dir_id = directory_id, |
| 207 | file_id = file_id) |
| 208 | session.add(link) |
| 209 | |
| 210 | # TODO consider how this effects committed |
| 211 | # Is it safe to just "update" it this way? |
| 212 | # SHould this be a built in method of WorkingDirFileLink |
| 213 | |
| 214 | link.file_id = task.file_id |
| 215 | |
| 216 | |
| 217 | def task_complete_transaction_normal(session, |
no test coverage detected