(self, event, data: dict, broadcast: bool)
| 671 | self.success = True |
| 672 | |
| 673 | def add_message(self, event, data: dict, broadcast: bool): |
| 674 | data = { |
| 675 | **data, |
| 676 | "timestamp": int(time.time() * 1000), |
| 677 | } |
| 678 | self.status_messages.append((event, data)) |
| 679 | if self.server.client_id is not None or broadcast: |
| 680 | self.server.send_sync(event, data, self.server.client_id) |
| 681 | |
| 682 | def handle_execution_error(self, prompt_id, prompt, current_outputs, executed, error, ex): |
| 683 | node_id = error["node_id"] |
no test coverage detected