(self, workflow, **kwargs)
| 631 | return spec |
| 632 | |
| 633 | def serialize_workflow(self, workflow, **kwargs): |
| 634 | assert isinstance(workflow, Workflow) |
| 635 | elem = etree.Element('workflow') |
| 636 | wf_spec_elem = self.serialize_workflow_spec(workflow.spec) |
| 637 | wf_spec_elem.tag = 'spec' |
| 638 | elem.append(wf_spec_elem) |
| 639 | |
| 640 | data_elem = SubElement(elem, 'data') |
| 641 | self.serialize_value_map(data_elem, workflow.data) |
| 642 | |
| 643 | if workflow.last_task is not None: |
| 644 | SubElement(elem, 'last-task').text = str(workflow.last_task.id) |
| 645 | |
| 646 | if workflow.success: |
| 647 | SubElement(elem, 'success') |
| 648 | task_tree_elem = SubElement(elem, 'task-tree') |
| 649 | task_tree_elem.append(self.serialize_task(workflow.task_tree)) |
| 650 | |
| 651 | return elem |
| 652 | |
| 653 | def deserialize_workflow(self, elem, **kwargs): |
| 654 | wf_spec_elem = elem.find('spec') |
nothing calls this directly
no test coverage detected