highfive/worker.py
async def handle_jobs(job_handler, host, port, *, loop):
    """
    Connects to the remote master and continuously receives calls, executes
    them, then returns a response until interrupted.
    """

    try:

        try:
            reader, writer = await asyncio.open_connection(host, port, loop=loop)
        except OSError:
            logging.error("worker could not connect to server")
            return

        while True:

            try:
                call_encoded = await reader.readuntil(b"\n")
            except (asyncio.IncompleteReadError, ConnectionResetError):
                break
            logging.debug("worker got call")
            call_json = call_encoded.decode("utf-8")
            call = json.loads(call_json)

            response = job_handler(call)

            response_json = json.dumps(response) + "\n"
            response_encoded = response_json.encode("utf-8")
            writer.write(response_encoded)
            logging.debug("worker returned response")

    except KeyboardInterrupt:

        pass
async def handle_jobs(job_handler, host, port, *, loop):
    """
    Connects to the remote master and continuously receives calls, executes
    them, then returns a response until interrupted.
    """

    try:

        try:
            reader, writer = await asyncio.open_connection(host, port, loop=loop)
        except OSError:
            logging.error("worker could not connect to server")
            return

        while True:

            try:
                call_encoded = await reader.readuntil(b"\n")
            except (asyncio.IncompleteReadError, ConnectionResetError):
                break
            logging.debug("worker got call")
            call_json = call_encoded.decode("utf-8")
            call = json.loads(call_json)

            response = job_handler(call)

            response_json = json.dumps(response) + "\n"
            response_encoded = response_json.encode("utf-8")
            writer.write(response_encoded)
            logging.debug("worker returned response")

    except KeyboardInterrupt:

        pass
async def handle_jobs ( job_handler , host , port , * , loop ) : try : try : reader , writer = await asyncio . open_connection ( host , port , loop = loop ) except OSError : logging . error ( "worker could not connect to server" ) return while True : try : call_encoded = await reader . readuntil ( b"\n" ) except ( asyncio . IncompleteReadError , ConnectionResetError ) : break logging . debug ( "worker got call" ) call_json = call_encoded . decode ( "utf-8" ) call = json . loads ( call_json ) response = job_handler ( call ) response_json = json . dumps ( response ) + "\n" response_encoded = response_json . encode ( "utf-8" ) writer . write ( response_encoded ) logging . debug ( "worker returned response" ) except KeyboardInterrupt : pass
Connects to the remote master and continuously receives calls, executes
    them, then returns a response until interrupted.
Connects to the remote master and continuously receives calls executes them then returns a response until interrupted .