async def METHOD_NAME(self, data):
    retry = True
    while True:
        try:
            if not retry:
                self._redis_connect()
            return await self.redis.publish(
                self.channel, pickle.dumps(data))
        except RedisError:
            if retry:
                self._get_logger().error('Cannot publish to redis... '
                                         'retrying')
                retry = False
            else:
                self._get_logger().error('Cannot publish to redis... '
                                         'giving up')
                break