def reset():
        """Resets the UCX library by shutting down all of UCX.
    
        The library is initiated at next API call.
        """
        global _ctx
        if _ctx is not None:
            weakref_ctx = weakref.ref(_ctx)
            _ctx = None
            gc.collect()
            if weakref_ctx() is not None:
                msg = (
                    "Trying to reset UCX but not all Endpoints and/or Listeners "
                    "are closed(). The following objects are still referencing "
                    "ApplicationContext: "
                )
                for o in gc.get_referrers(weakref_ctx()):
                    msg += "\n  %s" % str(o)
>               raise UCXError(msg)
E               ucp.exceptions.UCXError: Trying to reset UCX but not all Endpoints and/or Listeners are closed(). The following objects are still referencing ApplicationContext: 
E                 {'_ep': <ucp._libs.ucx_api.UCXEndpoint object at 0x7fe4d2cb5900>, '_ctx': <ucp.core.ApplicationContext object at 0x7fe4d2cb6460>, '_send_count': 1714, '_recv_count': 214, '_finished_recv_count': 214, '_shutting_down_peer': False, '_close_after_n_recv': None, '_tags': {'msg_send': 17641360423509091357, 'msg_recv': 858844837446935544, 'ctrl_send': 1644723418746821278, 'ctrl_recv': 523734172212257047}}