(self)
| 557 | self.wait(self._tpc_finish_gen("ROLLBACK", xid)) |
| 558 | |
| 559 | def tpc_recover(self) -> list[Xid]: |
| 560 | self._check_tpc() |
| 561 | status = self.info.transaction_status |
| 562 | with self.cursor(row_factory=args_row(Xid._from_record)) as cur: |
| 563 | cur.execute(Xid._get_recover_query()) |
| 564 | res = cur.fetchall() |
| 565 | |
| 566 | if status == IDLE and self.info.transaction_status == INTRANS: |
| 567 | self.rollback() |
| 568 | |
| 569 | return res |