

def _actor_new_handler(self, payload, status, **kwargs):
    ' Potentially created actor, reply to requesting node '
    msg = {
        'cmd': 'REPLY',
        'msg_uuid': payload['msg_uuid'],
        'value': status.encode(),
    }
    self.network.links[payload['from_rt_uuid']].send(msg)

dataset/ETHPy150Open EricssonResearch/calvin-base/calvin/runtime/north/calvin_proto.py CalvinProto._actor_new_handler/original