(self)
| 539 | yield from cur |
| 540 | |
| 541 | def now(self) -> datetime.datetime: |
| 542 | assert isinstance(self.conn, Connection) |
| 543 | with self.conn.cursor() as cur: |
| 544 | _logger.debug("Now Query. sql: %r", self.now_query) |
| 545 | cur.execute(self.now_query) |
| 546 | if one := cur.fetchone(): |
| 547 | return one[0] |
| 548 | else: |
| 549 | return datetime.datetime.now() |
| 550 | |
| 551 | def get_connection_id(self) -> int | None: |
| 552 | if not self.connection_id: |
no test coverage detected