(self)
| 672 | self.executor.process_wrapper.kill() |
| 673 | |
| 674 | def get_finish_output(self): |
| 675 | data = read_until_closed(self.executor.get_anonymized_output_stream(), timeout=BUFFER_FLUSH_WAIT_TIME) |
| 676 | output = ''.join(data) |
| 677 | return output |
| 678 | |
| 679 | def create_and_start_executor(self, config, parameter_values=None): |
| 680 | if parameter_values is None: |
no test coverage detected