def METHOD_NAME(conn_request):
    global ep
    ep = ucx_api.UCXEndpoint.create_from_conn_request(
        worker,
        conn_request,
        endpoint_error_handling=True,
    )
    # Wireup
    ucx_api.am_recv_nb(ep, cb_func=_recv_handle, cb_args=(ep,))
    # Data
    ucx_api.am_recv_nb(ep, cb_func=_recv_handle, cb_args=(ep,))