next up previous contents index
Next: Worker.run_cmd() run Up: Parallel job support Previous: Communicator.send_data() send   Contents   Index

Communicator.get_data() — get data

get_data(allow_heartbeat=False)
This gets the next piece of data available from the worker or manager. It must be matched by a corresponding Communicator.send_data() call at the other end, or an error will result. Errors are as for Communicator.send_data().