def _do_get(self):
        try:
            c = self._conn.current()
            if c:
                return c
        except __HOLE__:
            pass
        c = self._create_connection()
        self._conn.current = weakref.ref(c)
        if len(self._all_conns) >= self.size:
            self._cleanup()
        self._all_conns.add(c)
        return c
dataset/ETHPy150Open goFrendiAsgard/kokoropy/kokoropy/packages/sqlalchemy/pool.py/SingletonThreadPool._do_get