Return logging details for this workflow
(self, dct=None)
| 254 | return task.reset_branch(data) |
| 255 | |
| 256 | def collect_log_extras(self, dct=None): |
| 257 | """Return logging details for this workflow""" |
| 258 | extra = dct or {} |
| 259 | extra.update({ |
| 260 | 'workflow_spec': self.spec.name, |
| 261 | 'success': self.success, |
| 262 | 'completed': self.completed, |
| 263 | }) |
| 264 | if logger.level < 20: |
| 265 | extra.update({'tasks': [t.id for t in Workflow.get_tasks(self)]}) |
| 266 | return extra |
| 267 | |
| 268 | def _predict(self, mask=TaskState.NOT_FINISHED_MASK): |
| 269 | """Predict tasks with the provided mask""" |
no test coverage detected