Send data back to the client.
(ret_value)
| 74 | lock = threading.Lock() |
| 75 | |
| 76 | def _respond(ret_value): |
| 77 | """Send data back to the client.""" |
| 78 | data = cloudpickle.dumps(ret_value, protocol=pickle.HIGHEST_PROTOCOL) |
| 79 | writer.write(struct.pack("<i", len(data))) |
| 80 | writer.write(data) |
| 81 | writer.flush() |
| 82 | |
| 83 | def _cancel_run(status): |
| 84 | lock.acquire() |
no test coverage detected
searching dependent graphs…