async def METHOD_NAME(packed_remote_address):
    # Unpack the fixed-size address+tag buffer
    unpacked = _unpack_address_and_tag(packed_remote_address)
    remote_address = ucp.get_ucx_address_from_buffer(unpacked["address"])
    # Create endpoint to remote worker using the received address
    ep = await ucp.create_endpoint_from_worker_address(remote_address)
    # Send data to client's endpoint
    send_msg = np.arange(10, dtype=np.int64)
    await ep.send(send_msg, tag=unpacked["send_tag"], force_tag=True)
    # Receive data from client's endpoint
    recv_msg = np.empty(20, dtype=np.int64)
    await ep.recv(recv_msg, tag=unpacked["recv_tag"], force_tag=True)
    np.testing.assert_array_equal(recv_msg, np.arange(20, dtype=np.int64))