

def actor_migrate_handler(self, payload):
    ' Peer request new actor with state and connections '
    self.node.am.update_requirements(payload['actor_id'], payload['requirements'], payload['extend'], payload['move'], callback=CalvinCB(self._actor_migrate_handler, payload))

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