(
        self, rpc_message: RpcMessage, result_message: ResultMessage, return_path: str
    )
Send the result back to the caller
Send the result back to the caller
Send the result back to the caller
async def send_result(
        self, rpc_message: RpcMessage, result_message: ResultMessage, return_path: str
    ):
        """Send the result back to the caller"""
        logger.debug(
            L(
                "Sending result {} into Redis using return path {}",
                Bold(result_message),
                Bold(return_path),
            )
        )
        redis_key = self._parse_return_path(return_path)

        with await self.connection_manager() as redis:
            start_time = time.time()
            p = redis.pipeline()
            p.lpush(redis_key, self.serializer(result_message))
            p.expire(redis_key, timeout=self.result_ttl)
            await p.execute()

        logger.debug(
            L(
                "➡ Sent result {} into Redis in {} using return path {}",
                Bold(result_message),
                human_time(time.time() - start_time),
                Bold(return_path),
            )
        )
async def send_result ( self , rpc_message : RpcMessage , result_message : ResultMessage , return_path : str ) : logger . debug ( L ( "Sending result {} into Redis using return path {}" , Bold ( result_message ) , Bold ( return_path ) , ) ) redis_key = self . _parse_return_path ( return_path ) with await self . connection_manager ( ) as redis : start_time = time . time ( ) p = redis . pipeline ( ) p . lpush ( redis_key , self . serializer ( result_message ) ) p . expire ( redis_key , timeout = self . result_ttl ) await p . execute ( ) logger . debug ( L ( "➡ Sent result {} into Redis in {} using return path {}", Bold ( result_message ) , human_time ( time . time ( ) - start_time ) , Bold ( return_path ) , ) )