def datagram_received(self, data, sender): message = msgpack.unpackb(data, encoding='utf-8') self.orchestrator.data_received_peer(sender, message)