(self)
| 220 | yield txn_dict |
| 221 | |
| 222 | def _open_txn(self): |
| 223 | open_txn_req = OpenTxnRequest() |
| 224 | open_txn_req.num_txns = 1 |
| 225 | open_txn_req.user = "AcidTest" |
| 226 | open_txn_req.hostname = "localhost" |
| 227 | open_txn_resp = self.hive_client.open_txns(open_txn_req) |
| 228 | return open_txn_resp.txn_ids[0] |
| 229 | |
| 230 | def _commit_txn(self, txn_id): |
| 231 | commit_req = CommitTxnRequest() |
no test coverage detected