¿Cómo enviar un mensaje desde el proceso hijo a websocket-client en Tornado?

Tengo el servidor Tornado. Recibe mensajes de conexiones websocket. Necesito ejecutar la función del trabajador como un proceso separado y el trabajador debe responder al cliente. La idea principal es trabajar en modo paralelo. Algo como esto

def worker(ws,message): input = json.loads(message) t = input["time"] time.sleep(t) ws.write_message("Hello, World!"*int(t)) class MainHandler(tornado.web.RequestHandler): def get(self): self.render('index.html') class WebSocket(tornado.websocket.WebSocketHandler): def check_origin(self, origin): return True def open(self): print("WebSocket opened") self.application.webSocketsPool.append(self) def on_message(self, message): for key, value in enumerate(self.application.webSocketsPool): if value == self: p = Process(target=worker, args=(value.ws_connection,message,)) p.start() def on_close(self): print("WebSocket closed") for key, value in enumerate(self.application.webSocketsPool): if value == self: del self.application.webSocketsPool[key] 

Por supuesto, esto no funciona debido al error de decapado. ¿Cómo resolver este problema?