def METHOD_NAME(self) -> None:
    """Close all open connections"""
    with self.table_access_condition:
        curr_thread = threading.get_ident()
        self.conn[curr_thread].close()
        del self.conn[curr_thread]