(self, node)
| 554 | return future |
| 555 | |
| 556 | def run_node_future(self, node): |
| 557 | try: |
| 558 | node.valid_args(node.node_params, node.workflow_params) |
| 559 | self.send_progress(node) |
| 560 | result = self.run_node(node) |
| 561 | return NodeResultFuture(result, None, 200) |
| 562 | except Exception as e: |
| 563 | return NodeResultFuture(None, e, 500) |
| 564 | |
| 565 | def run_node(self, node): |
| 566 | result = node.run() |
no test coverage detected