import zmq

import marshal
import time
import types

context = zmq.Context(1)

socket = context.socket(zmq.REP)
socket.connect("ipc:///tmp/workers")

while True:
    data = socket.recv_pyobj()
    code = marshal.loads(data['code'])
    fn = types.FunctionType(code, globals(), "loaded_func")
    message = str(fn(*data['args']))
    socket.send(message)