def timeout_message(self, message_id):
        if message_id in self.send_timeout_map:
            del self.send_timeout_map[message_id]
        if message_id in self.send_future_map:
            self.send_future_map.pop(message_id).set_exception(
                SaltReqTimeoutError('Message timed out')
            )
dataset/ETHPy150Open saltstack/salt/salt/transport/tcp.py/SaltMessageClient.timeout_message/original