On demand killing.

gistfile1.py

            try:
                (r, w, e) = zmq.select([in_hb, in_cmd], [], [], timeout=end_time - time.time())

                for sock in r:
                    msg = sock.recv()

                    # ...
                    if sock == in_cmd:
                        print '[monitor] Order to execute'
                        all_is_well = False
                        retcode = 'Killed by order'
                        continue
            except ZMQError:
                # ...

            if not all_is_well:
                if not _kill(p):
                    print '[monitor] Probably already dead.'
                break