def add_ckpt_state(self, ckpt_id, ckpt_state):
<EOL>self._flush_remaining()<EOL>msg = ckptmgr_pb2.StoreInstanceStateCheckpoint()<EOL>istate = ckptmgr_pb2.InstanceStateCheckpoint()<EOL>istate.checkpoint_id = ckpt_id<EOL>istate.state = ckpt_state<EOL>msg.state.CopyFrom(istate)<EOL>self._push_tuple_to_stream(msg)<EOL>
Add the checkpoint state message to be sent back the stmgr

        :param ckpt_id: The id of the checkpoint
        :ckpt_state: The checkpoint state