(self, prefix)
| 1605 | raise exceptions.InterfaceError('connection is closed') |
| 1606 | |
| 1607 | def _get_unique_id(self, prefix): |
| 1608 | global _uid |
| 1609 | _uid += 1 |
| 1610 | return '__asyncpg_{}_{:x}__'.format(prefix, _uid) |
| 1611 | |
| 1612 | def _mark_stmts_as_closed(self): |
| 1613 | for stmt in self._stmt_cache.iter_statements(): |
no outgoing calls
no test coverage detected